Package org.consensusj.bitcoin.rx

Interface RxBlockchainBinaryService

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

RxBitcoinSinglePortZmqService, RxBitcoinZmqBinaryService, RxBitcoinZmqService

public interface RxBlockchainBinaryService
extends Closeable

For lower-level, higher-performance reactive subscriptions to blockchain data where we don't want the overhead of parsing (and instantiating as a tree of objects) each block or transaction. (e.g. a proxy or relay server) Note: Implementation instances may throw UnsupportedOperationException if they don't support a particular stream type.

Method Summary

Modifier and Type	Method	Description
org.reactivestreams.Publisher<byte[]>	blockBinaryPublisher()
org.reactivestreams.Publisher<byte[]>	blockHashBinaryPublisher()
org.reactivestreams.Publisher<byte[]>	transactionBinaryPublisher()
org.reactivestreams.Publisher<byte[]>	transactionHashBinaryPublisher()

Methods inherited from interface java.io.Closeable

close

Method Details

transactionBinaryPublisher

org.reactivestreams.Publisher<byte[]> transactionBinaryPublisher()

transactionHashBinaryPublisher

org.reactivestreams.Publisher<byte[]> transactionHashBinaryPublisher()

blockBinaryPublisher

org.reactivestreams.Publisher<byte[]> blockBinaryPublisher()

blockHashBinaryPublisher

org.reactivestreams.Publisher<byte[]> blockHashBinaryPublisher()