Package org.consensusj.bitcoin.rx.peergroup

Class RxPeerGroup

java.lang.Object

org.consensusj.bitcoin.rx.peergroup.RxPeerGroup

All Implemented Interfaces:

Closeable, AutoCloseable, RxBlockchainService

public class RxPeerGroup
extends Object
implements RxBlockchainService

Provide Reactive Publishers for PeerGroup information. This implementation works with a PeerGroup w/o a Blockchain/BlockStore.

Constructor Summary

Constructors

Constructor	Description
RxPeerGroup(org.bitcoinj.core.PeerGroup peerGroup)

Method Summary

Modifier and Type	Method	Description
org.reactivestreams.Publisher<org.bitcoinj.base.Sha256Hash>	blockHashPublisher()	TBD: Can BlocksDownloadedEventListener be used here?
org.reactivestreams.Publisher<Integer>	blockHeightPublisher()
org.reactivestreams.Publisher<org.bitcoinj.core.Block>	blockPublisher()	TBD: Can BlocksDownloadedEventListener be used here?
org.reactivestreams.Publisher<ChainTip>	chainTipPublisher()
void	close()
void	start()	TODO: Fix this.
org.reactivestreams.Publisher<org.bitcoinj.base.Sha256Hash>	transactionHashPublisher()
org.reactivestreams.Publisher<org.bitcoinj.core.Transaction>	transactionPublisher()

Methods inherited from class java.lang.Object

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

Constructor Details

RxPeerGroup

public RxPeerGroup(org.bitcoinj.core.PeerGroup peerGroup)

Method Details

start

public void start()

TODO: Fix this. RxPeerGroup implements BlockchainService which does not have a start() method. But if we move (@code start()} to the constructor, it breaks PeerWatcher.

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

transactionPublisher

public org.reactivestreams.Publisher<org.bitcoinj.core.Transaction> transactionPublisher()

Specified by:

transactionPublisher in interface RxBlockchainService

transactionHashPublisher

public org.reactivestreams.Publisher<org.bitcoinj.base.Sha256Hash> transactionHashPublisher()

Specified by:

transactionHashPublisher in interface RxBlockchainService

blockPublisher

public org.reactivestreams.Publisher<org.bitcoinj.core.Block> blockPublisher()

TBD: Can BlocksDownloadedEventListener be used here?

Specified by:

blockPublisher in interface RxBlockchainService

blockHashPublisher

public org.reactivestreams.Publisher<org.bitcoinj.base.Sha256Hash> blockHashPublisher()

TBD: Can BlocksDownloadedEventListener be used here?

Specified by:

blockHashPublisher in interface RxBlockchainService

blockHeightPublisher

public org.reactivestreams.Publisher<Integer> blockHeightPublisher()

Specified by:

blockHeightPublisher in interface RxBlockchainService

chainTipPublisher

public org.reactivestreams.Publisher<ChainTip> chainTipPublisher()

Specified by:

chainTipPublisher in interface RxBlockchainService