Package org.web3j.protocol.rx

Class JsonRpc2_0Rx

java.lang.Object

org.web3j.protocol.rx.JsonRpc2_0Rx

public class JsonRpc2_0Rx
extends java.lang.Object

web3j reactive API implementation.

Constructor Summary

Constructors

Constructor	Description
JsonRpc2_0Rx(Web3j web3j, java.util.concurrent.ScheduledExecutorService scheduledExecutorService)

Method Summary

Modifier and Type	Method	Description
io.reactivex.Flowable<EthBlock>	blockFlowable(boolean fullTransactionObjects, long pollingInterval)
io.reactivex.Flowable<java.lang.String>	ethBlockHashFlowable(long pollingInterval)
io.reactivex.Flowable<Log>	ethLogFlowable(EthFilter ethFilter, long pollingInterval)
io.reactivex.Flowable<java.lang.String>	ethPendingTransactionHashFlowable(long pollingInterval)
io.reactivex.Flowable<Transaction>	pendingTransactionFlowable(long pollingInterval)
io.reactivex.Flowable<EthBlock>	replayBlocksFlowable(DefaultBlockParameter startBlock, DefaultBlockParameter endBlock, boolean fullTransactionObjects)
io.reactivex.Flowable<EthBlock>	replayBlocksFlowable(DefaultBlockParameter startBlock, DefaultBlockParameter endBlock, boolean fullTransactionObjects, boolean ascending)
io.reactivex.Flowable<EthBlock>	replayPastAndFutureBlocksFlowable(DefaultBlockParameter startBlock, boolean fullTransactionObjects, long pollingInterval)
io.reactivex.Flowable<Transaction>	replayPastAndFutureTransactionsFlowable(DefaultBlockParameter startBlock, long pollingInterval)
io.reactivex.Flowable<EthBlock>	replayPastBlocksFlowable(DefaultBlockParameter startBlock, boolean fullTransactionObjects)
io.reactivex.Flowable<EthBlock>	replayPastBlocksFlowable(DefaultBlockParameter startBlock, boolean fullTransactionObjects, io.reactivex.Flowable<EthBlock> onCompleteFlowable)
io.reactivex.Flowable<Transaction>	replayPastTransactionsFlowable(DefaultBlockParameter startBlock)
io.reactivex.Flowable<Transaction>	replayTransactionsFlowable(DefaultBlockParameter startBlock, DefaultBlockParameter endBlock)
io.reactivex.Flowable<Transaction>	transactionFlowable(long pollingInterval)

Methods inherited from class java.lang.Object

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

Constructor Detail

JsonRpc2_0Rx

public JsonRpc2_0Rx(Web3j web3j,
                    java.util.concurrent.ScheduledExecutorService scheduledExecutorService)

Method Detail

ethBlockHashFlowable

public io.reactivex.Flowable<java.lang.String> ethBlockHashFlowable(long pollingInterval)

ethPendingTransactionHashFlowable

public io.reactivex.Flowable<java.lang.String> ethPendingTransactionHashFlowable(long pollingInterval)

ethLogFlowable

public io.reactivex.Flowable<Log> ethLogFlowable(EthFilter ethFilter,
                                                 long pollingInterval)

transactionFlowable

public io.reactivex.Flowable<Transaction> transactionFlowable(long pollingInterval)

pendingTransactionFlowable

public io.reactivex.Flowable<Transaction> pendingTransactionFlowable(long pollingInterval)

blockFlowable

public io.reactivex.Flowable<EthBlock> blockFlowable(boolean fullTransactionObjects,
                                                     long pollingInterval)

replayBlocksFlowable

public io.reactivex.Flowable<EthBlock> replayBlocksFlowable(DefaultBlockParameter startBlock,
                                                            DefaultBlockParameter endBlock,
                                                            boolean fullTransactionObjects)

replayBlocksFlowable

public io.reactivex.Flowable<EthBlock> replayBlocksFlowable(DefaultBlockParameter startBlock,
                                                            DefaultBlockParameter endBlock,
                                                            boolean fullTransactionObjects,
                                                            boolean ascending)

replayTransactionsFlowable

public io.reactivex.Flowable<Transaction> replayTransactionsFlowable(DefaultBlockParameter startBlock,
                                                                     DefaultBlockParameter endBlock)

replayPastBlocksFlowable

public io.reactivex.Flowable<EthBlock> replayPastBlocksFlowable(DefaultBlockParameter startBlock,
                                                                boolean fullTransactionObjects,
                                                                io.reactivex.Flowable<EthBlock> onCompleteFlowable)

replayPastBlocksFlowable

public io.reactivex.Flowable<EthBlock> replayPastBlocksFlowable(DefaultBlockParameter startBlock,
                                                                boolean fullTransactionObjects)

replayPastTransactionsFlowable

public io.reactivex.Flowable<Transaction> replayPastTransactionsFlowable(DefaultBlockParameter startBlock)

replayPastAndFutureBlocksFlowable

public io.reactivex.Flowable<EthBlock> replayPastAndFutureBlocksFlowable(DefaultBlockParameter startBlock,
                                                                         boolean fullTransactionObjects,
                                                                         long pollingInterval)

replayPastAndFutureTransactionsFlowable

public io.reactivex.Flowable<Transaction> replayPastAndFutureTransactionsFlowable(DefaultBlockParameter startBlock,
                                                                                  long pollingInterval)