bt.event

Class EventBus

java.lang.Object

bt.event.EventBus

All Implemented Interfaces:

EventSink, EventSource

public class EventBus
extends Object
implements EventSink, EventSource

Basic implementation of event bus, that connects event producers and listeners. In this implementation all events are delivered synchronously.

Since:

1.5

Constructor Summary

Constructors

Constructor and Description
EventBus()

Method Summary

Modifier and Type	Method and Description
void	fireMetadataAvailable(TorrentId torrentId, Torrent torrent) Generate event, that torrent's metadata has been fetched.
void	firePeerBitfieldUpdated(TorrentId torrentId, ConnectionKey connectionKey, Bitfield bitfield) Generate event, that local information about some peer's data has been updated.
void	firePeerConnected(ConnectionKey connectionKey) Generate event, that a new connection with some peer has been established.
void	firePeerDisconnected(ConnectionKey connectionKey) Generate event, that a connection with some peer has been terminated.
void	firePeerDiscovered(TorrentId torrentId, Peer peer) Generate event, that a new peer has been discovered for some torrent.
void	firePieceVerified(TorrentId torrentId, int pieceIndex) Generate event, that the downloading and verification of one of torrent's pieces has been finished.
void	fireTorrentStarted(TorrentId torrentId) Generate event, that processing of some torrent has begun.
void	fireTorrentStopped(TorrentId torrentId) Generate event, that processing of some torrent has finished.
EventSource	onMetadataAvailable(TorrentId torrentId, Consumer<MetadataAvailableEvent> listener) Fired, when torrent's metadata has been fetched.
EventSource	onPeerBitfieldUpdated(TorrentId torrentId, Consumer<PeerBitfieldUpdatedEvent> listener) Fired, when local information about some peer's data has been updated.
EventSource	onPeerConnected(TorrentId torrentId, Consumer<PeerConnectedEvent> listener) Fired, when a new connection with some peer has been established.
EventSource	onPeerDisconnected(TorrentId torrentId, Consumer<PeerDisconnectedEvent> listener) Fired, when a connection with some peer has been terminated.
EventSource	onPeerDiscovered(TorrentId torrentId, Consumer<PeerDiscoveredEvent> listener) Fired, when a new peer has been discovered for some torrent.
EventSource	onPieceVerified(TorrentId torrentId, Consumer<PieceVerifiedEvent> listener) Fired, when downloading and verification of one of torrent's pieces has been finished.
EventSource	onTorrentStarted(TorrentId torrentId, Consumer<TorrentStartedEvent> listener) Fired, when processing of some torrent has begun.
EventSource	onTorrentStopped(TorrentId torrentId, Consumer<TorrentStoppedEvent> listener) Fired, when processing of some torrent has finished.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EventBus

public EventBus()

Method Detail

firePeerDiscovered

public void firePeerDiscovered(TorrentId torrentId,
                               Peer peer)

Description copied from interface: EventSink

Generate event, that a new peer has been discovered for some torrent.

Specified by:

firePeerDiscovered in interface EventSink

firePeerConnected

public void firePeerConnected(ConnectionKey connectionKey)

Description copied from interface: EventSink

Generate event, that a new connection with some peer has been established.

Specified by:

firePeerConnected in interface EventSink

firePeerDisconnected

public void firePeerDisconnected(ConnectionKey connectionKey)

Description copied from interface: EventSink

Generate event, that a connection with some peer has been terminated.

Specified by:

firePeerDisconnected in interface EventSink

firePeerBitfieldUpdated

public void firePeerBitfieldUpdated(TorrentId torrentId,
                                    ConnectionKey connectionKey,
                                    Bitfield bitfield)

Description copied from interface: EventSink

Generate event, that local information about some peer's data has been updated.

Specified by:

firePeerBitfieldUpdated in interface EventSink

fireTorrentStarted

public void fireTorrentStarted(TorrentId torrentId)

Description copied from interface: EventSink

Generate event, that processing of some torrent has begun.

Specified by:

fireTorrentStarted in interface EventSink

fireMetadataAvailable

public void fireMetadataAvailable(TorrentId torrentId,
                                  Torrent torrent)

Description copied from interface: EventSink

Generate event, that torrent's metadata has been fetched.

Specified by:

fireMetadataAvailable in interface EventSink

fireTorrentStopped

public void fireTorrentStopped(TorrentId torrentId)

Description copied from interface: EventSink

Generate event, that processing of some torrent has finished.

Specified by:

fireTorrentStopped in interface EventSink

firePieceVerified

public void firePieceVerified(TorrentId torrentId,
                              int pieceIndex)

Description copied from interface: EventSink

Generate event, that the downloading and verification of one of torrent's pieces has been finished.

Specified by:

firePieceVerified in interface EventSink

onPeerDiscovered

public EventSource onPeerDiscovered(TorrentId torrentId,
                                    Consumer<PeerDiscoveredEvent> listener)

Description copied from interface: EventSource

Fired, when a new peer has been discovered for some torrent.

Specified by:

onPeerDiscovered in interface EventSource

onPeerConnected

public EventSource onPeerConnected(TorrentId torrentId,
                                   Consumer<PeerConnectedEvent> listener)

Description copied from interface: EventSource

Fired, when a new connection with some peer has been established.

Specified by:

onPeerConnected in interface EventSource

onPeerDisconnected

public EventSource onPeerDisconnected(TorrentId torrentId,
                                      Consumer<PeerDisconnectedEvent> listener)

Description copied from interface: EventSource

Fired, when a connection with some peer has been terminated.

Specified by:

onPeerDisconnected in interface EventSource

onPeerBitfieldUpdated

public EventSource onPeerBitfieldUpdated(TorrentId torrentId,
                                         Consumer<PeerBitfieldUpdatedEvent> listener)

Description copied from interface: EventSource

Fired, when local information about some peer's data has been updated.

Specified by:

onPeerBitfieldUpdated in interface EventSource

onTorrentStarted

public EventSource onTorrentStarted(TorrentId torrentId,
                                    Consumer<TorrentStartedEvent> listener)

Description copied from interface: EventSource

Fired, when processing of some torrent has begun.

Specified by:

onTorrentStarted in interface EventSource

onMetadataAvailable

public EventSource onMetadataAvailable(TorrentId torrentId,
                                       Consumer<MetadataAvailableEvent> listener)

Description copied from interface: EventSource

Fired, when torrent's metadata has been fetched.

Specified by:

onMetadataAvailable in interface EventSource

onTorrentStopped

public EventSource onTorrentStopped(TorrentId torrentId,
                                    Consumer<TorrentStoppedEvent> listener)

Description copied from interface: EventSource

Fired, when processing of some torrent has finished.

Specified by:

onTorrentStopped in interface EventSource

onPieceVerified

public EventSource onPieceVerified(TorrentId torrentId,
                                   Consumer<PieceVerifiedEvent> listener)

Description copied from interface: EventSource

Fired, when downloading and verification of one of torrent's pieces has been finished.

Specified by:

onPieceVerified in interface EventSource