Package org.consensusj.bitcoin.rx.jsonrpc

Interface RxJsonChainTipClient

All Superinterfaces:

AsyncSupport, ChainTipService, RxJsonRpcClient

@Deprecated
public interface RxJsonChainTipClient
extends ChainTipService, RxJsonRpcClient

Deprecated.

A JSON-RPC client interface that provides ChainTipService

Nested Class Summary

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

AsyncSupport.ThrowingSupplier<T>, AsyncSupport.TransientErrorFilter

Field Summary

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

log

Method Summary

Modifier and Type	Method	Description
default <RSLT> org.reactivestreams.Publisher<RSLT>	pollOnNewBlock(AsyncSupport.ThrowingSupplier<RSLT> method)	Deprecated.
default <RSLT> org.reactivestreams.Publisher<RSLT>	pollOnNewBlockAsync(Supplier<CompletionStage<RSLT>> supplier)	Deprecated. Repeatedly once-per-new-block poll an async method

Methods inherited from interface org.consensusj.jsonrpc.AsyncSupport

getDefaultAsyncExecutor, supplyAsync, supplyAsync

Methods inherited from interface org.consensusj.bitcoin.rx.ChainTipService

chainTipPublisher

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

call, callAsync, pollOnce, pollOnceAsPublisher, pollOnceAsPublisher, pollOnceAsync

Method Details

pollOnNewBlock

@Deprecated
default <RSLT> org.reactivestreams.Publisher<RSLT> pollOnNewBlock(AsyncSupport.ThrowingSupplier<RSLT> method)

Deprecated.

Repeatedly once-per-new-block poll a method

Type Parameters:

RSLT - The type of the expected result

Parameters:

method - A supplier (should be an RPC Method) that can throw Exception.

Returns:

An Observable for the expected result type, so we can expect one call to onNext per block.

pollOnNewBlockAsync

default <RSLT> org.reactivestreams.Publisher<RSLT> pollOnNewBlockAsync(Supplier<CompletionStage<RSLT>> supplier)

Deprecated.

Repeatedly once-per-new-block poll an async method

Type Parameters:

RSLT - The type of the expected result

Parameters:

supplier - A supplier (should be an RPC Method) of a CompletionStage

Returns:

An Observable for the expected result type, so we can expect one call to onNext per block.