public class JsonRpc2_0Rx
extends java.lang.Object
Constructor and Description |
---|
JsonRpc2_0Rx(Web3j web3j,
java.util.concurrent.ScheduledExecutorService scheduledExecutorService) |
Modifier and Type | Method and 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) |
public JsonRpc2_0Rx(Web3j web3j, java.util.concurrent.ScheduledExecutorService scheduledExecutorService)
public io.reactivex.Flowable<java.lang.String> ethBlockHashFlowable(long pollingInterval)
public io.reactivex.Flowable<java.lang.String> ethPendingTransactionHashFlowable(long pollingInterval)
public io.reactivex.Flowable<Log> ethLogFlowable(EthFilter ethFilter, long pollingInterval)
public io.reactivex.Flowable<Transaction> transactionFlowable(long pollingInterval)
public io.reactivex.Flowable<Transaction> pendingTransactionFlowable(long pollingInterval)
public io.reactivex.Flowable<EthBlock> blockFlowable(boolean fullTransactionObjects, long pollingInterval)
public io.reactivex.Flowable<EthBlock> replayBlocksFlowable(DefaultBlockParameter startBlock, DefaultBlockParameter endBlock, boolean fullTransactionObjects)
public io.reactivex.Flowable<EthBlock> replayBlocksFlowable(DefaultBlockParameter startBlock, DefaultBlockParameter endBlock, boolean fullTransactionObjects, boolean ascending)
public io.reactivex.Flowable<Transaction> replayTransactionsFlowable(DefaultBlockParameter startBlock, DefaultBlockParameter endBlock)
public io.reactivex.Flowable<EthBlock> replayPastBlocksFlowable(DefaultBlockParameter startBlock, boolean fullTransactionObjects, io.reactivex.Flowable<EthBlock> onCompleteFlowable)
public io.reactivex.Flowable<EthBlock> replayPastBlocksFlowable(DefaultBlockParameter startBlock, boolean fullTransactionObjects)
public io.reactivex.Flowable<Transaction> replayPastTransactionsFlowable(DefaultBlockParameter startBlock)
public io.reactivex.Flowable<EthBlock> replayPastAndFutureBlocksFlowable(DefaultBlockParameter startBlock, boolean fullTransactionObjects, long pollingInterval)
public io.reactivex.Flowable<Transaction> replayPastAndFutureTransactionsFlowable(DefaultBlockParameter startBlock, long pollingInterval)