Package org.consensusj.bitcoin.rx.jsonrpc

Class PollingChainTipServiceImpl

java.lang.Object

org.consensusj.bitcoin.rx.jsonrpc.PollingChainTipServiceImpl

All Implemented Interfaces:

Closeable, AutoCloseable, ChainTipClient, ChainTipService, AsyncSupport, RxJsonRpcClient

public class PollingChainTipServiceImpl
extends Object
implements ChainTipService, ChainTipClient, RxJsonRpcClient, Closeable

Provides ChainTipService a using a BitcoinClient and a polling interval. This can be used as a fallback if ZeroMQ is not available.

Nested Class Summary

Nested classes/interfaces inherited from interface org.consensusj.jsonrpc.AsyncSupport

AsyncSupport.ThrowingSupplier<T>, AsyncSupport.TransientErrorFilter

Constructor Summary

Constructors

Constructor	Description
PollingChainTipServiceImpl(BitcoinClient bitcoinClient)
PollingChainTipServiceImpl(BitcoinClient bitcoinClient, io.reactivex.rxjava3.core.Observable<Long> interval)	Construct from a BitcoinClient or subclass and a polling interval

Method Summary

Modifier and Type	Method	Description
ChainTipPublisher	chainTipPublisher()	This method will give you a stream of ChainTips
void	close()
List<ChainTip>	getChainTips()	Deprecated.
CompletableFuture<List<ChainTip>>	getChainTipsAsync()
io.reactivex.rxjava3.core.Observable<Long>	getPollingInterval()	Provide a polling interval
void	start()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.consensusj.jsonrpc.AsyncSupport

getDefaultAsyncExecutor, supplyAsync, supplyAsync

Methods inherited from interface org.consensusj.rx.jsonrpc.RxJsonRpcClient

call, callAsync, pollOnce, pollOnceAsPublisher, pollOnceAsPublisher, pollOnceAsync

Constructor Details

PollingChainTipServiceImpl

public PollingChainTipServiceImpl(BitcoinClient bitcoinClient,
 io.reactivex.rxjava3.core.Observable<Long> interval)

Construct from a BitcoinClient or subclass and a polling interval

Parameters:

bitcoinClient - a client instance

interval - a polling interval

PollingChainTipServiceImpl

public PollingChainTipServiceImpl(BitcoinClient bitcoinClient)

Method Details

start

public void start()

chainTipPublisher

public ChainTipPublisher chainTipPublisher()

Description copied from interface: ChainTipService

This method will give you a stream of ChainTips

Specified by:

chainTipPublisher in interface ChainTipService

Returns:

A Publisher for the sequence

getPollingInterval

public io.reactivex.rxjava3.core.Observable<Long> getPollingInterval()

Provide a polling interval

Returns:

polling interval with desired frequency for polling for new ChainTips.

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

getChainTipsAsync

public CompletableFuture<List<ChainTip>> getChainTipsAsync()

Specified by:

getChainTipsAsync in interface ChainTipClient

getChainTips

@Deprecated
public List<ChainTip> getChainTips()
                            throws JsonRpcStatusException,
IOException

Deprecated.

Specified by:

getChainTips in interface ChainTipClient

Throws:

JsonRpcStatusException

IOException