public interface Web3jRx
Modifier and Type | Method and Description |
---|---|
rx.Observable<EthBlock> |
blockObservable(boolean fullTransactionObjects)
Create an Observable that emits newly created blocks on the blockchain.
|
rx.Observable<EthBlock> |
catchUpToLatestAndSubscribeToNewBlocksObservable(DefaultBlockParameter startBlock,
boolean fullTransactionObjects)
Creates an Observable that emits all blocks from the requested block number to the most
current.
|
rx.Observable<Transaction> |
catchUpToLatestAndSubscribeToNewTransactionsObservable(DefaultBlockParameter startBlock)
As per
catchUpToLatestAndSubscribeToNewBlocksObservable(DefaultBlockParameter, boolean) ,
except that all transactions contained within the blocks are emitted. |
rx.Observable<EthBlock> |
catchUpToLatestBlockObservable(DefaultBlockParameter startBlock,
boolean fullTransactionObjects)
Creates an Observable that emits all blocks from the requested block number to the most
current.
|
rx.Observable<EthBlock> |
catchUpToLatestBlockObservable(DefaultBlockParameter startBlock,
boolean fullTransactionObjects,
rx.Observable<EthBlock> onCompleteObservable)
Create an Observable that emits all transactions from the blockchain starting with a
provided block number.
|
rx.Observable<Transaction> |
catchUpToLatestTransactionObservable(DefaultBlockParameter startBlock)
Creates an Observable that emits all transactions from the requested block number to the most
current.
|
rx.Observable<java.lang.String> |
ethBlockHashObservable()
Create an Observable to emit block hashes.
|
rx.Observable<Log> |
ethLogObservable(EthFilter ethFilter)
Create an observable to filter for specific log events on the blockchain.
|
rx.Observable<java.lang.String> |
ethPendingTransactionHashObservable()
Create an Observable to emit pending transactions, i.e.
|
rx.Observable<LogNotification> |
logsNotifications(java.util.List<java.lang.String> addresses,
java.util.List<java.lang.String> topics)
Creates an observable that emits notifications for logs included in new imported blocks.
|
rx.Observable<NewHeadsNotification> |
newHeadsNotifications()
Creates an observable that emits a notification when a new header is appended to a chain,
including chain reorganizations.
|
rx.Observable<Transaction> |
pendingTransactionObservable()
Create an Observable to emit all pending transactions that have yet to be placed into a
block on the blockchain.
|
rx.Observable<EthBlock> |
replayBlocksObservable(DefaultBlockParameter startBlock,
DefaultBlockParameter endBlock,
boolean fullTransactionObjects)
Create an Observable that emits all blocks from the blockchain contained within the
requested range.
|
rx.Observable<EthBlock> |
replayBlocksObservable(DefaultBlockParameter startBlock,
DefaultBlockParameter endBlock,
boolean fullTransactionObjects,
boolean ascending)
Create an Observable that emits all blocks from the blockchain contained within the
requested range.
|
rx.Observable<Transaction> |
replayTransactionsObservable(DefaultBlockParameter startBlock,
DefaultBlockParameter endBlock)
Create an Observable that emits all transactions from the blockchain contained within the
requested range.
|
rx.Observable<Transaction> |
transactionObservable()
Create an Observable to emit all new transactions as they are confirmed on the blockchain.
|
rx.Observable<Log> ethLogObservable(EthFilter ethFilter)
ethFilter
- filter criteriarx.Observable<java.lang.String> ethBlockHashObservable()
rx.Observable<java.lang.String> ethPendingTransactionHashObservable()
rx.Observable<Transaction> transactionObservable()
rx.Observable<Transaction> pendingTransactionObservable()
rx.Observable<EthBlock> blockObservable(boolean fullTransactionObjects)
fullTransactionObjects
- if true, provides transactions embedded in blocks, otherwise
transaction hashesrx.Observable<EthBlock> replayBlocksObservable(DefaultBlockParameter startBlock, DefaultBlockParameter endBlock, boolean fullTransactionObjects)
startBlock
- block number to commence withendBlock
- block number to finish withfullTransactionObjects
- if true, provides transactions embedded in blocks, otherwise
transaction hashesrx.Observable<EthBlock> replayBlocksObservable(DefaultBlockParameter startBlock, DefaultBlockParameter endBlock, boolean fullTransactionObjects, boolean ascending)
startBlock
- block number to commence withendBlock
- block number to finish withfullTransactionObjects
- if true, provides transactions embedded in blocks, otherwise
transaction hashesascending
- if true, emits blocks in ascending order between range, otherwise
in descending orderrx.Observable<Transaction> replayTransactionsObservable(DefaultBlockParameter startBlock, DefaultBlockParameter endBlock)
startBlock
- block number to commence withendBlock
- block number to finish withrx.Observable<EthBlock> catchUpToLatestBlockObservable(DefaultBlockParameter startBlock, boolean fullTransactionObjects, rx.Observable<EthBlock> onCompleteObservable)
To automatically subscribe to new blocks, use
catchUpToLatestAndSubscribeToNewBlocksObservable(DefaultBlockParameter, boolean)
.
startBlock
- the block number we wish to request fromfullTransactionObjects
- if we require full Transaction
objects to be provided
in the EthBlock
responsesonCompleteObservable
- a subsequent Observable that we wish to run once we are caught
up with the latest blockrx.Observable<EthBlock> catchUpToLatestBlockObservable(DefaultBlockParameter startBlock, boolean fullTransactionObjects)
startBlock
- the block number we wish to request fromfullTransactionObjects
- if we require full Transaction
objects to be provided
in the EthBlock
responsesrx.Observable<Transaction> catchUpToLatestTransactionObservable(DefaultBlockParameter startBlock)
startBlock
- the block number we wish to request fromrx.Observable<EthBlock> catchUpToLatestAndSubscribeToNewBlocksObservable(DefaultBlockParameter startBlock, boolean fullTransactionObjects)
startBlock
- the block number we wish to request fromfullTransactionObjects
- if we require full Transaction
objects to be provided
in the EthBlock
responsesrx.Observable<Transaction> catchUpToLatestAndSubscribeToNewTransactionsObservable(DefaultBlockParameter startBlock)
catchUpToLatestAndSubscribeToNewBlocksObservable(DefaultBlockParameter, boolean)
,
except that all transactions contained within the blocks are emitted.startBlock
- the block number we wish to request fromrx.Observable<NewHeadsNotification> newHeadsNotifications()
rx.Observable<LogNotification> logsNotifications(java.util.List<java.lang.String> addresses, java.util.List<java.lang.String> topics)
addresses
- only return logs from this list of address. Return logs from all addresses
if the list is emptytopics
- only return logs that match specified topics. Returns logs for all topics if
the list is empty