Package org.consensusj.bitcoin.rx.zeromq

Class RxBitcoinSinglePortZmqService

java.lang.Object

org.consensusj.bitcoin.rx.zeromq.RxBitcoinSinglePortZmqService

All Implemented Interfaces:

Closeable, AutoCloseable, RxBlockchainBinaryService

public class RxBitcoinSinglePortZmqService
extends Object
implements RxBlockchainBinaryService, Closeable

Bitcoin Zmq binary service that connects to a single port. Use RxBitcoinZmqBinaryService if Bitcoin Core is configured to run ZMQ on multiple ports. See: PR 19752 for sequence topic information

Constructor Summary

Constructors

Constructor	Description
RxBitcoinSinglePortZmqService(URI tcpAddress, ThreadFactory threadFactory, BitcoinZmqMessage.Topic... topics)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

RxBitcoinSinglePortZmqService

public RxBitcoinSinglePortZmqService(URI tcpAddress,
 ThreadFactory threadFactory,
 BitcoinZmqMessage.Topic... topics)

Method Details

transactionBinaryPublisher

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

Specified by:

transactionBinaryPublisher in interface RxBlockchainBinaryService

transactionHashBinaryPublisher

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

Specified by:

transactionHashBinaryPublisher in interface RxBlockchainBinaryService

blockBinaryPublisher

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

Specified by:

blockBinaryPublisher in interface RxBlockchainBinaryService

blockHashBinaryPublisher

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

Specified by:

blockHashBinaryPublisher in interface RxBlockchainBinaryService

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable