Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_BLOCK_TIME |
protected Web3jService |
web3jService |
Constructor and Description |
---|
JsonRpc2_0Web3j(Web3jService web3jService) |
JsonRpc2_0Web3j(Web3jService web3jService,
long pollingInterval,
java.util.concurrent.ScheduledExecutorService scheduledExecutorService) |
Modifier and Type | Method and Description |
---|---|
Request<?,AdminNodeInfo> |
adminNodeInfo() |
Request<?,AdminPeers> |
adminPeers() |
io.reactivex.Flowable<EthBlock> |
blockFlowable(boolean fullTransactionObjects)
Create an
Flowable instance that emits newly created blocks on the blockchain. |
Request<?,DbGetHex> |
dbGetHex(java.lang.String databaseName,
java.lang.String keyName) |
Request<?,DbGetString> |
dbGetString(java.lang.String databaseName,
java.lang.String keyName) |
Request<?,DbPutHex> |
dbPutHex(java.lang.String databaseName,
java.lang.String keyName,
java.lang.String dataToStore) |
Request<?,DbPutString> |
dbPutString(java.lang.String databaseName,
java.lang.String keyName,
java.lang.String stringToStore) |
Request<?,EthAccounts> |
ethAccounts() |
io.reactivex.Flowable<java.lang.String> |
ethBlockHashFlowable()
Create an Flowable to emit block hashes.
|
Request<?,EthBlockNumber> |
ethBlockNumber() |
Request<?,EthCall> |
ethCall(Transaction transaction,
DefaultBlockParameter defaultBlockParameter) |
Request<?,EthChainId> |
ethChainId() |
Request<?,EthCoinbase> |
ethCoinbase() |
Request<?,EthCompileLLL> |
ethCompileLLL(java.lang.String sourceCode) |
Request<?,EthCompileSerpent> |
ethCompileSerpent(java.lang.String sourceCode) |
Request<?,EthCompileSolidity> |
ethCompileSolidity(java.lang.String sourceCode) |
Request<?,EthEstimateGas> |
ethEstimateGas(Transaction transaction) |
Request<?,EthGasPrice> |
ethGasPrice() |
Request<?,EthGetBalance> |
ethGetBalance(java.lang.String address,
DefaultBlockParameter defaultBlockParameter) |
Request<?,EthBlock> |
ethGetBlockByHash(java.lang.String blockHash,
boolean returnFullTransactionObjects) |
Request<?,EthBlock> |
ethGetBlockByNumber(DefaultBlockParameter defaultBlockParameter,
boolean returnFullTransactionObjects) |
Request<?,EthGetBlockTransactionCountByHash> |
ethGetBlockTransactionCountByHash(java.lang.String blockHash) |
Request<?,EthGetBlockTransactionCountByNumber> |
ethGetBlockTransactionCountByNumber(DefaultBlockParameter defaultBlockParameter) |
Request<?,EthGetCode> |
ethGetCode(java.lang.String address,
DefaultBlockParameter defaultBlockParameter) |
Request<?,EthGetCompilers> |
ethGetCompilers() |
Request<?,EthLog> |
ethGetFilterChanges(java.math.BigInteger filterId) |
Request<?,EthLog> |
ethGetFilterLogs(java.math.BigInteger filterId) |
Request<?,EthLog> |
ethGetLogs(EthFilter ethFilter) |
Request<?,EthGetStorageAt> |
ethGetStorageAt(java.lang.String address,
java.math.BigInteger position,
DefaultBlockParameter defaultBlockParameter) |
Request<?,EthTransaction> |
ethGetTransactionByBlockHashAndIndex(java.lang.String blockHash,
java.math.BigInteger transactionIndex) |
Request<?,EthTransaction> |
ethGetTransactionByBlockNumberAndIndex(DefaultBlockParameter defaultBlockParameter,
java.math.BigInteger transactionIndex) |
Request<?,EthTransaction> |
ethGetTransactionByHash(java.lang.String transactionHash) |
Request<?,EthGetTransactionCount> |
ethGetTransactionCount(java.lang.String address,
DefaultBlockParameter defaultBlockParameter) |
Request<?,EthGetTransactionReceipt> |
ethGetTransactionReceipt(java.lang.String transactionHash) |
Request<?,EthBlock> |
ethGetUncleByBlockHashAndIndex(java.lang.String blockHash,
java.math.BigInteger transactionIndex) |
Request<?,EthBlock> |
ethGetUncleByBlockNumberAndIndex(DefaultBlockParameter defaultBlockParameter,
java.math.BigInteger uncleIndex) |
Request<?,EthGetUncleCountByBlockHash> |
ethGetUncleCountByBlockHash(java.lang.String blockHash) |
Request<?,EthGetUncleCountByBlockNumber> |
ethGetUncleCountByBlockNumber(DefaultBlockParameter defaultBlockParameter) |
Request<?,EthGetWork> |
ethGetWork() |
Request<?,EthHashrate> |
ethHashrate() |
io.reactivex.Flowable<Log> |
ethLogFlowable(EthFilter ethFilter)
Create an flowable to filter for specific log events on the blockchain.
|
Request<?,EthMining> |
ethMining() |
Request<?,EthFilter> |
ethNewBlockFilter() |
Request<?,EthFilter> |
ethNewFilter(EthFilter ethFilter) |
Request<?,EthFilter> |
ethNewPendingTransactionFilter() |
io.reactivex.Flowable<java.lang.String> |
ethPendingTransactionHashFlowable()
Create an Flowable to emit pending transactions, i.e.
|
Request<?,EthProtocolVersion> |
ethProtocolVersion() |
Request<?,EthSendTransaction> |
ethSendRawTransaction(java.lang.String signedTransactionData) |
Request<?,EthSendTransaction> |
ethSendTransaction(Transaction transaction) |
Request<?,EthSign> |
ethSign(java.lang.String address,
java.lang.String sha3HashOfDataToSign) |
Request<?,EthSubmitHashrate> |
ethSubmitHashrate(java.lang.String hashrate,
java.lang.String clientId) |
Request<?,EthSubmitWork> |
ethSubmitWork(java.lang.String nonce,
java.lang.String headerPowHash,
java.lang.String mixDigest) |
Request<?,EthSyncing> |
ethSyncing() |
Request<?,EthUninstallFilter> |
ethUninstallFilter(java.math.BigInteger filterId) |
io.reactivex.Flowable<LogNotification> |
logsNotifications(java.util.List<java.lang.String> addresses,
java.util.List<java.lang.String> topics)
Creates aa
Flowable instance that emits notifications for logs included in new
imported blocks. |
Request<?,NetListening> |
netListening() |
Request<?,NetPeerCount> |
netPeerCount() |
Request<?,NetVersion> |
netVersion() |
BatchRequest |
newBatch()
Create a new
BatchRequest . |
io.reactivex.Flowable<NewHeadsNotification> |
newHeadsNotifications()
Creates a
Flowable instance that emits a notification when a new header is appended
to a chain, including chain reorganizations. |
io.reactivex.Flowable<Transaction> |
pendingTransactionFlowable()
Create an
Flowable instance to emit all pending transactions that have yet to be
placed into a block on the blockchain. |
io.reactivex.Flowable<EthBlock> |
replayPastAndFutureBlocksFlowable(DefaultBlockParameter startBlock,
boolean fullTransactionObjects)
Creates a
Flowable instance that emits all blocks from the requested block number to
the most current. |
io.reactivex.Flowable<Transaction> |
replayPastAndFutureTransactionsFlowable(DefaultBlockParameter startBlock)
As per
Web3jRx.replayPastAndFutureBlocksFlowable(DefaultBlockParameter, boolean) , except
that all transactions contained within the blocks are emitted. |
io.reactivex.Flowable<EthBlock> |
replayPastBlocksFlowable(DefaultBlockParameter startBlock,
boolean fullTransactionObjects)
Creates a
Flowable instance that emits all blocks from the requested block number to
the most current. |
io.reactivex.Flowable<EthBlock> |
replayPastBlocksFlowable(DefaultBlockParameter startBlock,
boolean fullTransactionObjects,
io.reactivex.Flowable<EthBlock> onCompleteFlowable)
Create a
Flowable instance that emits all transactions from the blockchain starting
with a provided block number. |
io.reactivex.Flowable<EthBlock> |
replayPastBlocksFlowable(DefaultBlockParameter startBlock,
DefaultBlockParameter endBlock,
boolean fullTransactionObjects)
Create an
Flowable instance that emits all blocks from the blockchain contained
within the requested range. |
io.reactivex.Flowable<EthBlock> |
replayPastBlocksFlowable(DefaultBlockParameter startBlock,
DefaultBlockParameter endBlock,
boolean fullTransactionObjects,
boolean ascending)
Create an
Flowable instance that emits all blocks from the blockchain contained
within the requested range. |
io.reactivex.Flowable<Transaction> |
replayPastTransactionsFlowable(DefaultBlockParameter startBlock)
Creates a
Flowable instance that emits all transactions from the requested block
number to the most current. |
io.reactivex.Flowable<Transaction> |
replayPastTransactionsFlowable(DefaultBlockParameter startBlock,
DefaultBlockParameter endBlock)
Create a
Flowable instance that emits all transactions from the blockchain contained
within the requested range. |
Request<?,ShhAddToGroup> |
shhAddToGroup(java.lang.String identityAddress) |
Request<?,ShhMessages> |
shhGetFilterChanges(java.math.BigInteger filterId) |
Request<?,ShhMessages> |
shhGetMessages(java.math.BigInteger filterId) |
Request<?,ShhHasIdentity> |
shhHasIdentity(java.lang.String identityAddress) |
Request<?,ShhNewFilter> |
shhNewFilter(ShhFilter shhFilter) |
Request<?,ShhNewGroup> |
shhNewGroup() |
Request<?,ShhNewIdentity> |
shhNewIdentity() |
Request<?,ShhPost> |
shhPost(ShhPost shhPost) |
Request<?,ShhUninstallFilter> |
shhUninstallFilter(java.math.BigInteger filterId) |
Request<?,ShhVersion> |
shhVersion() |
void |
shutdown()
Shutdowns a Web3j instance and closes opened resources.
|
io.reactivex.Flowable<Transaction> |
transactionFlowable()
Create an
Flowable instance to emit all new transactions as they are confirmed on the
blockchain. |
Request<?,Web3ClientVersion> |
web3ClientVersion() |
Request<?,Web3Sha3> |
web3Sha3(java.lang.String data) |
public static final int DEFAULT_BLOCK_TIME
protected final Web3jService web3jService
public JsonRpc2_0Web3j(Web3jService web3jService)
public JsonRpc2_0Web3j(Web3jService web3jService, long pollingInterval, java.util.concurrent.ScheduledExecutorService scheduledExecutorService)
public Request<?,Web3ClientVersion> web3ClientVersion()
web3ClientVersion
in interface Ethereum
public Request<?,NetVersion> netVersion()
netVersion
in interface Ethereum
public Request<?,NetListening> netListening()
netListening
in interface Ethereum
public Request<?,NetPeerCount> netPeerCount()
netPeerCount
in interface Ethereum
public Request<?,AdminNodeInfo> adminNodeInfo()
adminNodeInfo
in interface Ethereum
public Request<?,AdminPeers> adminPeers()
adminPeers
in interface Ethereum
public Request<?,EthProtocolVersion> ethProtocolVersion()
ethProtocolVersion
in interface Ethereum
public Request<?,EthChainId> ethChainId()
ethChainId
in interface Ethereum
public Request<?,EthCoinbase> ethCoinbase()
ethCoinbase
in interface Ethereum
public Request<?,EthSyncing> ethSyncing()
ethSyncing
in interface Ethereum
public Request<?,EthHashrate> ethHashrate()
ethHashrate
in interface Ethereum
public Request<?,EthGasPrice> ethGasPrice()
ethGasPrice
in interface Ethereum
public Request<?,EthAccounts> ethAccounts()
ethAccounts
in interface Ethereum
public Request<?,EthBlockNumber> ethBlockNumber()
ethBlockNumber
in interface Ethereum
public Request<?,EthGetBalance> ethGetBalance(java.lang.String address, DefaultBlockParameter defaultBlockParameter)
ethGetBalance
in interface Ethereum
public Request<?,EthGetStorageAt> ethGetStorageAt(java.lang.String address, java.math.BigInteger position, DefaultBlockParameter defaultBlockParameter)
ethGetStorageAt
in interface Ethereum
public Request<?,EthGetTransactionCount> ethGetTransactionCount(java.lang.String address, DefaultBlockParameter defaultBlockParameter)
ethGetTransactionCount
in interface Ethereum
public Request<?,EthGetBlockTransactionCountByHash> ethGetBlockTransactionCountByHash(java.lang.String blockHash)
ethGetBlockTransactionCountByHash
in interface Ethereum
public Request<?,EthGetBlockTransactionCountByNumber> ethGetBlockTransactionCountByNumber(DefaultBlockParameter defaultBlockParameter)
ethGetBlockTransactionCountByNumber
in interface Ethereum
public Request<?,EthGetUncleCountByBlockHash> ethGetUncleCountByBlockHash(java.lang.String blockHash)
ethGetUncleCountByBlockHash
in interface Ethereum
public Request<?,EthGetUncleCountByBlockNumber> ethGetUncleCountByBlockNumber(DefaultBlockParameter defaultBlockParameter)
ethGetUncleCountByBlockNumber
in interface Ethereum
public Request<?,EthGetCode> ethGetCode(java.lang.String address, DefaultBlockParameter defaultBlockParameter)
ethGetCode
in interface Ethereum
public Request<?,EthSign> ethSign(java.lang.String address, java.lang.String sha3HashOfDataToSign)
public Request<?,EthSendTransaction> ethSendTransaction(Transaction transaction)
ethSendTransaction
in interface Ethereum
public Request<?,EthSendTransaction> ethSendRawTransaction(java.lang.String signedTransactionData)
ethSendRawTransaction
in interface Ethereum
public Request<?,EthCall> ethCall(Transaction transaction, DefaultBlockParameter defaultBlockParameter)
public Request<?,EthEstimateGas> ethEstimateGas(Transaction transaction)
ethEstimateGas
in interface Ethereum
public Request<?,EthBlock> ethGetBlockByHash(java.lang.String blockHash, boolean returnFullTransactionObjects)
ethGetBlockByHash
in interface Ethereum
public Request<?,EthBlock> ethGetBlockByNumber(DefaultBlockParameter defaultBlockParameter, boolean returnFullTransactionObjects)
ethGetBlockByNumber
in interface Ethereum
public Request<?,EthTransaction> ethGetTransactionByHash(java.lang.String transactionHash)
ethGetTransactionByHash
in interface Ethereum
public Request<?,EthTransaction> ethGetTransactionByBlockHashAndIndex(java.lang.String blockHash, java.math.BigInteger transactionIndex)
ethGetTransactionByBlockHashAndIndex
in interface Ethereum
public Request<?,EthTransaction> ethGetTransactionByBlockNumberAndIndex(DefaultBlockParameter defaultBlockParameter, java.math.BigInteger transactionIndex)
ethGetTransactionByBlockNumberAndIndex
in interface Ethereum
public Request<?,EthGetTransactionReceipt> ethGetTransactionReceipt(java.lang.String transactionHash)
ethGetTransactionReceipt
in interface Ethereum
public Request<?,EthBlock> ethGetUncleByBlockHashAndIndex(java.lang.String blockHash, java.math.BigInteger transactionIndex)
ethGetUncleByBlockHashAndIndex
in interface Ethereum
public Request<?,EthBlock> ethGetUncleByBlockNumberAndIndex(DefaultBlockParameter defaultBlockParameter, java.math.BigInteger uncleIndex)
ethGetUncleByBlockNumberAndIndex
in interface Ethereum
public Request<?,EthGetCompilers> ethGetCompilers()
ethGetCompilers
in interface Ethereum
public Request<?,EthCompileLLL> ethCompileLLL(java.lang.String sourceCode)
ethCompileLLL
in interface Ethereum
public Request<?,EthCompileSolidity> ethCompileSolidity(java.lang.String sourceCode)
ethCompileSolidity
in interface Ethereum
public Request<?,EthCompileSerpent> ethCompileSerpent(java.lang.String sourceCode)
ethCompileSerpent
in interface Ethereum
public Request<?,EthFilter> ethNewFilter(EthFilter ethFilter)
ethNewFilter
in interface Ethereum
public Request<?,EthFilter> ethNewBlockFilter()
ethNewBlockFilter
in interface Ethereum
public Request<?,EthFilter> ethNewPendingTransactionFilter()
ethNewPendingTransactionFilter
in interface Ethereum
public Request<?,EthUninstallFilter> ethUninstallFilter(java.math.BigInteger filterId)
ethUninstallFilter
in interface Ethereum
public Request<?,EthLog> ethGetFilterChanges(java.math.BigInteger filterId)
ethGetFilterChanges
in interface Ethereum
public Request<?,EthLog> ethGetFilterLogs(java.math.BigInteger filterId)
ethGetFilterLogs
in interface Ethereum
public Request<?,EthLog> ethGetLogs(EthFilter ethFilter)
ethGetLogs
in interface Ethereum
public Request<?,EthGetWork> ethGetWork()
ethGetWork
in interface Ethereum
public Request<?,EthSubmitWork> ethSubmitWork(java.lang.String nonce, java.lang.String headerPowHash, java.lang.String mixDigest)
ethSubmitWork
in interface Ethereum
public Request<?,EthSubmitHashrate> ethSubmitHashrate(java.lang.String hashrate, java.lang.String clientId)
ethSubmitHashrate
in interface Ethereum
public Request<?,DbPutString> dbPutString(java.lang.String databaseName, java.lang.String keyName, java.lang.String stringToStore)
dbPutString
in interface Ethereum
public Request<?,DbGetString> dbGetString(java.lang.String databaseName, java.lang.String keyName)
dbGetString
in interface Ethereum
public Request<?,DbPutHex> dbPutHex(java.lang.String databaseName, java.lang.String keyName, java.lang.String dataToStore)
public Request<?,DbGetHex> dbGetHex(java.lang.String databaseName, java.lang.String keyName)
public Request<?,ShhVersion> shhVersion()
shhVersion
in interface Ethereum
public Request<?,ShhNewIdentity> shhNewIdentity()
shhNewIdentity
in interface Ethereum
public Request<?,ShhHasIdentity> shhHasIdentity(java.lang.String identityAddress)
shhHasIdentity
in interface Ethereum
public Request<?,ShhNewGroup> shhNewGroup()
shhNewGroup
in interface Ethereum
public Request<?,ShhAddToGroup> shhAddToGroup(java.lang.String identityAddress)
shhAddToGroup
in interface Ethereum
public Request<?,ShhNewFilter> shhNewFilter(ShhFilter shhFilter)
shhNewFilter
in interface Ethereum
public Request<?,ShhUninstallFilter> shhUninstallFilter(java.math.BigInteger filterId)
shhUninstallFilter
in interface Ethereum
public Request<?,ShhMessages> shhGetFilterChanges(java.math.BigInteger filterId)
shhGetFilterChanges
in interface Ethereum
public Request<?,ShhMessages> shhGetMessages(java.math.BigInteger filterId)
shhGetMessages
in interface Ethereum
public io.reactivex.Flowable<NewHeadsNotification> newHeadsNotifications()
Web3jRx
Flowable
instance that emits a notification when a new header is appended
to a chain, including chain reorganizations.newHeadsNotifications
in interface Web3jRx
Flowable
instance that emits a notification for every new headerpublic io.reactivex.Flowable<LogNotification> logsNotifications(java.util.List<java.lang.String> addresses, java.util.List<java.lang.String> topics)
Web3jRx
Flowable
instance that emits notifications for logs included in new
imported blocks.logsNotifications
in interface Web3jRx
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 emptyFlowable
instance that emits logs included in new blockspublic io.reactivex.Flowable<java.lang.String> ethBlockHashFlowable()
Web3jRx
ethBlockHashFlowable
in interface Web3jRx
Flowable
instance that emits all new block hashes as new blocks are created
on the blockchainpublic io.reactivex.Flowable<java.lang.String> ethPendingTransactionHashFlowable()
Web3jRx
ethPendingTransactionHashFlowable
in interface Web3jRx
Flowable
instance to emit pending transaction hashes.public io.reactivex.Flowable<Log> ethLogFlowable(EthFilter ethFilter)
Web3jRx
ethLogFlowable
in interface Web3jRx
ethFilter
- filter criteriaFlowable
instance that emits all Log events matching the filterpublic io.reactivex.Flowable<Transaction> transactionFlowable()
Web3jRx
Flowable
instance to emit all new transactions as they are confirmed on the
blockchain. i.e. they have been mined and are incorporated into a block.transactionFlowable
in interface Web3jRx
Flowable
instance to emit new transactions on the blockchainpublic io.reactivex.Flowable<Transaction> pendingTransactionFlowable()
Web3jRx
Flowable
instance to emit all pending transactions that have yet to be
placed into a block on the blockchain.pendingTransactionFlowable
in interface Web3jRx
Flowable
instance to emit pending transactionspublic io.reactivex.Flowable<EthBlock> blockFlowable(boolean fullTransactionObjects)
Web3jRx
Flowable
instance that emits newly created blocks on the blockchain.blockFlowable
in interface Web3jRx
fullTransactionObjects
- if true, provides transactions embedded in blocks, otherwise
transaction hashesFlowable
instance that emits all new blocks as they are added to the
blockchainpublic io.reactivex.Flowable<EthBlock> replayPastBlocksFlowable(DefaultBlockParameter startBlock, DefaultBlockParameter endBlock, boolean fullTransactionObjects)
Web3jRx
Flowable
instance that emits all blocks from the blockchain contained
within the requested range.replayPastBlocksFlowable
in interface Web3jRx
startBlock
- block number to commence withendBlock
- block number to finish withfullTransactionObjects
- if true, provides transactions embedded in blocks, otherwise
transaction hashesFlowable
instance to emit these blockspublic io.reactivex.Flowable<EthBlock> replayPastBlocksFlowable(DefaultBlockParameter startBlock, DefaultBlockParameter endBlock, boolean fullTransactionObjects, boolean ascending)
Web3jRx
Flowable
instance that emits all blocks from the blockchain contained
within the requested range.replayPastBlocksFlowable
in interface Web3jRx
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 orderFlowable
instance to emit these blockspublic io.reactivex.Flowable<EthBlock> replayPastBlocksFlowable(DefaultBlockParameter startBlock, boolean fullTransactionObjects, io.reactivex.Flowable<EthBlock> onCompleteFlowable)
Web3jRx
Flowable
instance that emits all transactions from the blockchain starting
with a provided block number. Once it has replayed up to the most current block, the provided
Flowable is invoked.
To automatically subscribe to new blocks, use Web3jRx.replayPastAndFutureBlocksFlowable(DefaultBlockParameter, boolean)
.
replayPastBlocksFlowable
in interface Web3jRx
startBlock
- the block number we wish to request fromfullTransactionObjects
- if we require full Transaction
objects to be provided
in the EthBlock
responsesonCompleteFlowable
- a subsequent Flowable that we wish to run once we are caught up
with the latest blockFlowable
instance to emit all requested blockspublic io.reactivex.Flowable<EthBlock> replayPastBlocksFlowable(DefaultBlockParameter startBlock, boolean fullTransactionObjects)
Web3jRx
Flowable
instance that emits all blocks from the requested block number to
the most current. Once it has emitted the most current block, onComplete is called.replayPastBlocksFlowable
in interface Web3jRx
startBlock
- the block number we wish to request fromfullTransactionObjects
- if we require full Transaction
objects to be provided
in the EthBlock
responsesFlowable
instance to emit all requested blockspublic io.reactivex.Flowable<Transaction> replayPastTransactionsFlowable(DefaultBlockParameter startBlock, DefaultBlockParameter endBlock)
Web3jRx
Flowable
instance that emits all transactions from the blockchain contained
within the requested range.replayPastTransactionsFlowable
in interface Web3jRx
startBlock
- block number to commence withendBlock
- block number to finish withFlowable
instance to emit these transactions in the order they appear in
the blockspublic io.reactivex.Flowable<Transaction> replayPastTransactionsFlowable(DefaultBlockParameter startBlock)
Web3jRx
Flowable
instance that emits all transactions from the requested block
number to the most current. Once it has emitted the most current block's transactions,
onComplete is called.replayPastTransactionsFlowable
in interface Web3jRx
startBlock
- the block number we wish to request fromFlowable
instance to emit all requested transactionspublic io.reactivex.Flowable<EthBlock> replayPastAndFutureBlocksFlowable(DefaultBlockParameter startBlock, boolean fullTransactionObjects)
Web3jRx
Flowable
instance that emits all blocks from the requested block number to
the most current. Once it has emitted the most current block, it starts emitting new blocks
as they are created.replayPastAndFutureBlocksFlowable
in interface Web3jRx
startBlock
- the block number we wish to request fromfullTransactionObjects
- if we require full Transaction
objects to be provided
in the EthBlock
responsesFlowable
instance to emit all requested blocks and futurepublic io.reactivex.Flowable<Transaction> replayPastAndFutureTransactionsFlowable(DefaultBlockParameter startBlock)
Web3jRx
Web3jRx.replayPastAndFutureBlocksFlowable(DefaultBlockParameter, boolean)
, except
that all transactions contained within the blocks are emitted.replayPastAndFutureTransactionsFlowable
in interface Web3jRx
startBlock
- the block number we wish to request fromFlowable
instance to emit all requested transactions and futurepublic void shutdown()
Web3j
public BatchRequest newBatch()
Batcher
BatchRequest
.