Package org.consensusj.bitcoin.rx.jsonrpc.service

Class TxOutSetService

java.lang.Object

org.consensusj.bitcoin.rx.jsonrpc.service.TxOutSetService

All Implemented Interfaces:

Closeable, AutoCloseable

public class TxOutSetService
extends Object
implements Closeable

Service to return a stream of TxOutSetInfos for a given blockchain/client. Updates are triggered on new blocks (via ChainTipService a cache is used to prevent fetches of TxOutSetInfos already fetched (e.g. on blockchain re-org) and MAX_OUTSTANDING_CALLS is used to prevent overloading the server (e.g. during blockchain sync)

Constructor Summary

Constructors

Constructor	Description
TxOutSetService(RxBitcoinClient client, ChainTipPublisher chainTipPublisher)

Method Summary

Modifier and Type	Method	Description
void	close()
org.reactivestreams.Publisher<TxOutSetInfo>	getTxOutSetPublisher()

Methods inherited from class java.lang.Object

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

Constructor Details

TxOutSetService

public TxOutSetService(RxBitcoinClient client,
 ChainTipPublisher chainTipPublisher)

Parameters:

client - Client for requesting TxOutSetInfo objects.

chainTipPublisher - Publisher telling us when new blocks are available.

Method Details

getTxOutSetPublisher

public org.reactivestreams.Publisher<TxOutSetInfo> getTxOutSetPublisher()

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable