Package org.consensusj.bitcoin.rx

Interface RxBlockchainService

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

RxBitcoinZmqService, RxPeerGroup

public interface RxBlockchainService
extends Closeable

Reactive Streams interface for subscribing to reactive blockchain data. There are at least 3 possible implementations 1. A bitcoinj PeerGroup 2. The ZeroMQ (and JSON-RPC) service of a trusted Bitcoin Core node 3. A Bitcoin web service using WebSocket Note: Implementation instances may throw UnsupportedOperationException if they don't support a particular published data type.

Method Summary

Modifier and Type	Method	Description
org.reactivestreams.Publisher<org.bitcoinj.base.Sha256Hash>	blockHashPublisher()
org.reactivestreams.Publisher<Integer>	blockHeightPublisher()
org.reactivestreams.Publisher<org.bitcoinj.core.Block>	blockPublisher()
org.reactivestreams.Publisher<ChainTip>	chainTipPublisher()
org.reactivestreams.Publisher<org.bitcoinj.base.Sha256Hash>	transactionHashPublisher()
org.reactivestreams.Publisher<org.bitcoinj.core.Transaction>	transactionPublisher()

Methods inherited from interface java.io.Closeable

close

Method Details

transactionPublisher

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

transactionHashPublisher

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

blockPublisher

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

blockHashPublisher

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

blockHeightPublisher

org.reactivestreams.Publisher<Integer> blockHeightPublisher()

chainTipPublisher

org.reactivestreams.Publisher<ChainTip> chainTipPublisher()