Package org.consensusj.bitcoin.rx.zeromq

Class RxBitcoinZmqService

java.lang.Object

org.consensusj.bitcoin.rx.zeromq.RxBitcoinZmqBinaryService

org.consensusj.bitcoin.rx.zeromq.RxBitcoinZmqService

All Implemented Interfaces:

Closeable, AutoCloseable, ChainTipService, RxBlockchainBinaryService, RxBlockchainService

public class RxBitcoinZmqService
extends RxBitcoinZmqBinaryService
implements RxBlockchainService, ChainTipService, Closeable

Add conversion to bitcoinj-types to RxBitcoinZmqBinaryService. Also uses the JSON-RPC client to fetch an initial Block so subscribers don't have to wait ~ten minutes for one.

Field Summary

Fields inherited from class org.consensusj.bitcoin.rx.zeromq.RxBitcoinZmqBinaryService

client

Constructor Summary

Constructors

Constructor	Description
RxBitcoinZmqService(org.bitcoinj.base.Network network, URI rpcUri, String rpcUser, String rpcPassword)
RxBitcoinZmqService(BitcoinClient client)

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()
ChainTipPublisher	chainTipPublisher()	This method will give you a stream of ChainTips
void	close()
org.reactivestreams.Publisher<org.bitcoinj.base.Sha256Hash>	transactionHashPublisher()
org.reactivestreams.Publisher<org.bitcoinj.core.Transaction>	transactionPublisher()

Methods inherited from class org.consensusj.bitcoin.rx.zeromq.RxBitcoinZmqBinaryService

blockBinaryPublisher, blockHashBinaryPublisher, transactionBinaryPublisher, transactionHashBinaryPublisher

Methods inherited from class java.lang.Object

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

Constructor Details

RxBitcoinZmqService

public RxBitcoinZmqService(org.bitcoinj.base.Network network,
 URI rpcUri,
 String rpcUser,
 String rpcPassword)

RxBitcoinZmqService

public RxBitcoinZmqService(BitcoinClient client)

Method Details

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()

Specified by:

blockPublisher in interface RxBlockchainService

blockHashPublisher

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

Specified by:

blockHashPublisher in interface RxBlockchainService

blockHeightPublisher

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

Specified by:

blockHeightPublisher in interface RxBlockchainService

chainTipPublisher

public ChainTipPublisher chainTipPublisher()

Description copied from interface: ChainTipService

This method will give you a stream of ChainTips

Specified by:

chainTipPublisher in interface ChainTipService

Specified by:

chainTipPublisher in interface RxBlockchainService

Returns:

A Publisher for the sequence

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class RxBitcoinZmqBinaryService