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 |
---|---|
rx.Observable<EthBlock> |
blockObservable(boolean fullTransactionObjects,
long pollingInterval) |
rx.Observable<EthBlock> |
catchUpToLatestAndSubscribeToNewBlocksObservable(DefaultBlockParameter startBlock,
boolean fullTransactionObjects,
long pollingInterval) |
rx.Observable<Transaction> |
catchUpToLatestAndSubscribeToNewTransactionsObservable(DefaultBlockParameter startBlock,
long pollingInterval) |
rx.Observable<EthBlock> |
catchUpToLatestBlockObservable(DefaultBlockParameter startBlock,
boolean fullTransactionObjects) |
rx.Observable<EthBlock> |
catchUpToLatestBlockObservable(DefaultBlockParameter startBlock,
boolean fullTransactionObjects,
rx.Observable<EthBlock> onCompleteObservable) |
rx.Observable<Transaction> |
catchUpToLatestTransactionObservable(DefaultBlockParameter startBlock) |
rx.Observable<java.lang.String> |
ethBlockHashObservable(long pollingInterval) |
rx.Observable<Log> |
ethLogObservable(EthFilter ethFilter,
long pollingInterval) |
rx.Observable<java.lang.String> |
ethPendingTransactionHashObservable(long pollingInterval) |
rx.Observable<Transaction> |
pendingTransactionObservable(long pollingInterval) |
rx.Observable<EthBlock> |
replayBlocksObservable(DefaultBlockParameter startBlock,
DefaultBlockParameter endBlock,
boolean fullTransactionObjects) |
rx.Observable<EthBlock> |
replayBlocksObservable(DefaultBlockParameter startBlock,
DefaultBlockParameter endBlock,
boolean fullTransactionObjects,
boolean ascending) |
rx.Observable<Transaction> |
replayTransactionsObservable(DefaultBlockParameter startBlock,
DefaultBlockParameter endBlock) |
rx.Observable<Transaction> |
transactionObservable(long pollingInterval) |
public JsonRpc2_0Rx(Web3j web3j, java.util.concurrent.ScheduledExecutorService scheduledExecutorService)
public rx.Observable<java.lang.String> ethBlockHashObservable(long pollingInterval)
public rx.Observable<java.lang.String> ethPendingTransactionHashObservable(long pollingInterval)
public rx.Observable<Log> ethLogObservable(EthFilter ethFilter, long pollingInterval)
public rx.Observable<Transaction> transactionObservable(long pollingInterval)
public rx.Observable<Transaction> pendingTransactionObservable(long pollingInterval)
public rx.Observable<EthBlock> blockObservable(boolean fullTransactionObjects, long pollingInterval)
public rx.Observable<EthBlock> replayBlocksObservable(DefaultBlockParameter startBlock, DefaultBlockParameter endBlock, boolean fullTransactionObjects)
public rx.Observable<EthBlock> replayBlocksObservable(DefaultBlockParameter startBlock, DefaultBlockParameter endBlock, boolean fullTransactionObjects, boolean ascending)
public rx.Observable<Transaction> replayTransactionsObservable(DefaultBlockParameter startBlock, DefaultBlockParameter endBlock)
public rx.Observable<EthBlock> catchUpToLatestBlockObservable(DefaultBlockParameter startBlock, boolean fullTransactionObjects, rx.Observable<EthBlock> onCompleteObservable)
public rx.Observable<EthBlock> catchUpToLatestBlockObservable(DefaultBlockParameter startBlock, boolean fullTransactionObjects)
public rx.Observable<Transaction> catchUpToLatestTransactionObservable(DefaultBlockParameter startBlock)
public rx.Observable<EthBlock> catchUpToLatestAndSubscribeToNewBlocksObservable(DefaultBlockParameter startBlock, boolean fullTransactionObjects, long pollingInterval)
public rx.Observable<Transaction> catchUpToLatestAndSubscribeToNewTransactionsObservable(DefaultBlockParameter startBlock, long pollingInterval)