org.web3j.protocol.core

类 JsonRpc2_0Web3j

java.lang.Object

org.web3j.protocol.core.JsonRpc2_0Web3j

所有已实现的接口:

Ethereum, Web3jRx, Web3j

直接已知子类:

JsonRpc2_0Admin

public class JsonRpc2_0Web3j
extends java.lang.Object
implements Web3j

JSON-RPC 2.0 factory implementation.

字段概要

字段

限定符和类型	字段和说明
static int	DEFAULT_BLOCK_TIME
protected Web3jService	web3jService

构造器概要

构造器

构造器和说明
JsonRpc2_0Web3j(Web3jService web3jService)
JsonRpc2_0Web3j(Web3jService web3jService, long pollingInterval, java.util.concurrent.ScheduledExecutorService scheduledExecutorService)

方法概要

限定符和类型	方法和说明
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 Web3jRx.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.
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()
rx.Observable<java.lang.String>	ethBlockHashObservable() Create an Observable to emit block hashes.
Request<?,EthBlockNumber>	ethBlockNumber()
Request<?,EthCall>	ethCall(Transaction transaction, DefaultBlockParameter defaultBlockParameter)
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()
rx.Observable<Log>	ethLogObservable(EthFilter ethFilter) Create an observable to filter for specific log events on the blockchain.
Request<?,EthMining>	ethMining()
Request<?,EthFilter>	ethNewBlockFilter()
Request<?,EthFilter>	ethNewFilter(EthFilter ethFilter)
Request<?,EthFilter>	ethNewPendingTransactionFilter()
rx.Observable<java.lang.String>	ethPendingTransactionHashObservable() Create an Observable to emit pending transactions, i.e. those transactions that have been submitted by a node, but don't yet form part of a block (haven't been mined yet).
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)
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.
Request<?,NetListening>	netListening()
Request<?,NetPeerCount>	netPeerCount()
Request<?,NetVersion>	netVersion()
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.
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.
rx.Observable<Transaction>	transactionObservable() Create an Observable to emit all new transactions as they are confirmed on the blockchain.
Request<?,Web3ClientVersion>	web3ClientVersion()
Request<?,Web3Sha3>	web3Sha3(java.lang.String data)

从类继承的方法 java.lang.Object

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

从接口继承的方法 org.web3j.protocol.Web3j

build, build

字段详细资料

DEFAULT_BLOCK_TIME

public static final int DEFAULT_BLOCK_TIME

另请参阅:

常量字段值

web3jService

protected final Web3jService web3jService

构造器详细资料

JsonRpc2_0Web3j

public JsonRpc2_0Web3j(Web3jService web3jService)

JsonRpc2_0Web3j

public JsonRpc2_0Web3j(Web3jService web3jService,
                       long pollingInterval,
                       java.util.concurrent.ScheduledExecutorService scheduledExecutorService)

方法详细资料

web3ClientVersion

public Request<?,Web3ClientVersion> web3ClientVersion()

指定者:

web3ClientVersion 在接口中 Ethereum

web3Sha3

public Request<?,Web3Sha3> web3Sha3(java.lang.String data)

指定者:

web3Sha3 在接口中 Ethereum

netVersion

public Request<?,NetVersion> netVersion()

指定者:

netVersion 在接口中 Ethereum

netListening

public Request<?,NetListening> netListening()

指定者:

netListening 在接口中 Ethereum

netPeerCount

public Request<?,NetPeerCount> netPeerCount()

指定者:

netPeerCount 在接口中 Ethereum

ethProtocolVersion

public Request<?,EthProtocolVersion> ethProtocolVersion()

指定者:

ethProtocolVersion 在接口中 Ethereum

ethCoinbase

public Request<?,EthCoinbase> ethCoinbase()

指定者:

ethCoinbase 在接口中 Ethereum

ethSyncing

public Request<?,EthSyncing> ethSyncing()

指定者:

ethSyncing 在接口中 Ethereum

ethMining

public Request<?,EthMining> ethMining()

指定者:

ethMining 在接口中 Ethereum

ethHashrate

public Request<?,EthHashrate> ethHashrate()

指定者:

ethHashrate 在接口中 Ethereum

ethGasPrice

public Request<?,EthGasPrice> ethGasPrice()

指定者:

ethGasPrice 在接口中 Ethereum

ethAccounts

public Request<?,EthAccounts> ethAccounts()

指定者:

ethAccounts 在接口中 Ethereum

ethBlockNumber

public Request<?,EthBlockNumber> ethBlockNumber()

指定者:

ethBlockNumber 在接口中 Ethereum

ethGetBalance

public Request<?,EthGetBalance> ethGetBalance(java.lang.String address,
                                              DefaultBlockParameter defaultBlockParameter)

指定者:

ethGetBalance 在接口中 Ethereum

ethGetStorageAt

public Request<?,EthGetStorageAt> ethGetStorageAt(java.lang.String address,
                                                  java.math.BigInteger position,
                                                  DefaultBlockParameter defaultBlockParameter)

指定者:

ethGetStorageAt 在接口中 Ethereum

ethGetTransactionCount

public Request<?,EthGetTransactionCount> ethGetTransactionCount(java.lang.String address,
                                                                DefaultBlockParameter defaultBlockParameter)

指定者:

ethGetTransactionCount 在接口中 Ethereum

ethGetBlockTransactionCountByHash

public Request<?,EthGetBlockTransactionCountByHash> ethGetBlockTransactionCountByHash(java.lang.String blockHash)

指定者:

ethGetBlockTransactionCountByHash 在接口中 Ethereum

ethGetBlockTransactionCountByNumber

public Request<?,EthGetBlockTransactionCountByNumber> ethGetBlockTransactionCountByNumber(DefaultBlockParameter defaultBlockParameter)

指定者:

ethGetBlockTransactionCountByNumber 在接口中 Ethereum

ethGetUncleCountByBlockHash

public Request<?,EthGetUncleCountByBlockHash> ethGetUncleCountByBlockHash(java.lang.String blockHash)

指定者:

ethGetUncleCountByBlockHash 在接口中 Ethereum

ethGetUncleCountByBlockNumber

public Request<?,EthGetUncleCountByBlockNumber> ethGetUncleCountByBlockNumber(DefaultBlockParameter defaultBlockParameter)

指定者:

ethGetUncleCountByBlockNumber 在接口中 Ethereum

ethGetCode

public Request<?,EthGetCode> ethGetCode(java.lang.String address,
                                        DefaultBlockParameter defaultBlockParameter)

指定者:

ethGetCode 在接口中 Ethereum

ethSign

public Request<?,EthSign> ethSign(java.lang.String address,
                                  java.lang.String sha3HashOfDataToSign)

指定者:

ethSign 在接口中 Ethereum

ethSendTransaction

public Request<?,EthSendTransaction> ethSendTransaction(Transaction transaction)

指定者:

ethSendTransaction 在接口中 Ethereum

ethSendRawTransaction

public Request<?,EthSendTransaction> ethSendRawTransaction(java.lang.String signedTransactionData)

指定者:

ethSendRawTransaction 在接口中 Ethereum

ethCall

public Request<?,EthCall> ethCall(Transaction transaction,
                                  DefaultBlockParameter defaultBlockParameter)

指定者:

ethCall 在接口中 Ethereum

ethEstimateGas

public Request<?,EthEstimateGas> ethEstimateGas(Transaction transaction)

指定者:

ethEstimateGas 在接口中 Ethereum

ethGetBlockByHash

public Request<?,EthBlock> ethGetBlockByHash(java.lang.String blockHash,
                                             boolean returnFullTransactionObjects)

指定者:

ethGetBlockByHash 在接口中 Ethereum

ethGetBlockByNumber

public Request<?,EthBlock> ethGetBlockByNumber(DefaultBlockParameter defaultBlockParameter,
                                               boolean returnFullTransactionObjects)

指定者:

ethGetBlockByNumber 在接口中 Ethereum

ethGetTransactionByHash

public Request<?,EthTransaction> ethGetTransactionByHash(java.lang.String transactionHash)

指定者:

ethGetTransactionByHash 在接口中 Ethereum

ethGetTransactionByBlockHashAndIndex

public Request<?,EthTransaction> ethGetTransactionByBlockHashAndIndex(java.lang.String blockHash,
                                                                      java.math.BigInteger transactionIndex)

指定者:

ethGetTransactionByBlockHashAndIndex 在接口中 Ethereum

ethGetTransactionByBlockNumberAndIndex

public Request<?,EthTransaction> ethGetTransactionByBlockNumberAndIndex(DefaultBlockParameter defaultBlockParameter,
                                                                        java.math.BigInteger transactionIndex)

指定者:

ethGetTransactionByBlockNumberAndIndex 在接口中 Ethereum

ethGetTransactionReceipt

public Request<?,EthGetTransactionReceipt> ethGetTransactionReceipt(java.lang.String transactionHash)

指定者:

ethGetTransactionReceipt 在接口中 Ethereum

ethGetUncleByBlockHashAndIndex

public Request<?,EthBlock> ethGetUncleByBlockHashAndIndex(java.lang.String blockHash,
                                                          java.math.BigInteger transactionIndex)

指定者:

ethGetUncleByBlockHashAndIndex 在接口中 Ethereum

ethGetUncleByBlockNumberAndIndex

public Request<?,EthBlock> ethGetUncleByBlockNumberAndIndex(DefaultBlockParameter defaultBlockParameter,
                                                            java.math.BigInteger uncleIndex)

指定者:

ethGetUncleByBlockNumberAndIndex 在接口中 Ethereum

ethGetCompilers

public Request<?,EthGetCompilers> ethGetCompilers()

指定者:

ethGetCompilers 在接口中 Ethereum

ethCompileLLL

public Request<?,EthCompileLLL> ethCompileLLL(java.lang.String sourceCode)

指定者:

ethCompileLLL 在接口中 Ethereum

ethCompileSolidity

public Request<?,EthCompileSolidity> ethCompileSolidity(java.lang.String sourceCode)

指定者:

ethCompileSolidity 在接口中 Ethereum

ethCompileSerpent

public Request<?,EthCompileSerpent> ethCompileSerpent(java.lang.String sourceCode)

指定者:

ethCompileSerpent 在接口中 Ethereum

ethNewFilter

public Request<?,EthFilter> ethNewFilter(EthFilter ethFilter)

指定者:

ethNewFilter 在接口中 Ethereum

ethNewBlockFilter

public Request<?,EthFilter> ethNewBlockFilter()

指定者:

ethNewBlockFilter 在接口中 Ethereum

ethNewPendingTransactionFilter

public Request<?,EthFilter> ethNewPendingTransactionFilter()

指定者:

ethNewPendingTransactionFilter 在接口中 Ethereum

ethUninstallFilter

public Request<?,EthUninstallFilter> ethUninstallFilter(java.math.BigInteger filterId)

指定者:

ethUninstallFilter 在接口中 Ethereum

ethGetFilterChanges

public Request<?,EthLog> ethGetFilterChanges(java.math.BigInteger filterId)

指定者:

ethGetFilterChanges 在接口中 Ethereum

ethGetFilterLogs

public Request<?,EthLog> ethGetFilterLogs(java.math.BigInteger filterId)

指定者:

ethGetFilterLogs 在接口中 Ethereum

ethGetLogs

public Request<?,EthLog> ethGetLogs(EthFilter ethFilter)

指定者:

ethGetLogs 在接口中 Ethereum

ethGetWork

public Request<?,EthGetWork> ethGetWork()

指定者:

ethGetWork 在接口中 Ethereum

ethSubmitWork

public Request<?,EthSubmitWork> ethSubmitWork(java.lang.String nonce,
                                              java.lang.String headerPowHash,
                                              java.lang.String mixDigest)

指定者:

ethSubmitWork 在接口中 Ethereum

ethSubmitHashrate

public Request<?,EthSubmitHashrate> ethSubmitHashrate(java.lang.String hashrate,
                                                      java.lang.String clientId)

指定者:

ethSubmitHashrate 在接口中 Ethereum

dbPutString

public Request<?,DbPutString> dbPutString(java.lang.String databaseName,
                                          java.lang.String keyName,
                                          java.lang.String stringToStore)

指定者:

dbPutString 在接口中 Ethereum

dbGetString

public Request<?,DbGetString> dbGetString(java.lang.String databaseName,
                                          java.lang.String keyName)

指定者:

dbGetString 在接口中 Ethereum

dbPutHex

public Request<?,DbPutHex> dbPutHex(java.lang.String databaseName,
                                    java.lang.String keyName,
                                    java.lang.String dataToStore)

指定者:

dbPutHex 在接口中 Ethereum

dbGetHex

public Request<?,DbGetHex> dbGetHex(java.lang.String databaseName,
                                    java.lang.String keyName)

指定者:

dbGetHex 在接口中 Ethereum

shhPost

public Request<?,ShhPost> shhPost(ShhPost shhPost)

指定者:

shhPost 在接口中 Ethereum

shhVersion

public Request<?,ShhVersion> shhVersion()

指定者:

shhVersion 在接口中 Ethereum

shhNewIdentity

public Request<?,ShhNewIdentity> shhNewIdentity()

指定者:

shhNewIdentity 在接口中 Ethereum

shhHasIdentity

public Request<?,ShhHasIdentity> shhHasIdentity(java.lang.String identityAddress)

指定者:

shhHasIdentity 在接口中 Ethereum

shhNewGroup

public Request<?,ShhNewGroup> shhNewGroup()

指定者:

shhNewGroup 在接口中 Ethereum

shhAddToGroup

public Request<?,ShhAddToGroup> shhAddToGroup(java.lang.String identityAddress)

指定者:

shhAddToGroup 在接口中 Ethereum

shhNewFilter

public Request<?,ShhNewFilter> shhNewFilter(ShhFilter shhFilter)

指定者:

shhNewFilter 在接口中 Ethereum

shhUninstallFilter

public Request<?,ShhUninstallFilter> shhUninstallFilter(java.math.BigInteger filterId)

指定者:

shhUninstallFilter 在接口中 Ethereum

shhGetFilterChanges

public Request<?,ShhMessages> shhGetFilterChanges(java.math.BigInteger filterId)

指定者:

shhGetFilterChanges 在接口中 Ethereum

shhGetMessages

public Request<?,ShhMessages> shhGetMessages(java.math.BigInteger filterId)

指定者:

shhGetMessages 在接口中 Ethereum

newHeadsNotifications

public rx.Observable<NewHeadsNotification> newHeadsNotifications()

从接口复制的说明: Web3jRx

Creates an observable that emits a notification when a new header is appended to a chain, including chain reorganizations.

指定者:

newHeadsNotifications 在接口中 Web3jRx

返回:

Observable that emits a notification for every new header

logsNotifications

public rx.Observable<LogNotification> logsNotifications(java.util.List<java.lang.String> addresses,
                                                        java.util.List<java.lang.String> topics)

从接口复制的说明: Web3jRx

Creates an observable that emits notifications for logs included in new imported blocks.

指定者:

logsNotifications 在接口中 Web3jRx

参数:

addresses - only return logs from this list of address. Return logs from all addresses if the list is empty

topics - only return logs that match specified topics. Returns logs for all topics if the list is empty

返回:

Observable that emits logs included in new blocks

ethBlockHashObservable

public rx.Observable<java.lang.String> ethBlockHashObservable()

从接口复制的说明: Web3jRx

Create an Observable to emit block hashes.

指定者:

ethBlockHashObservable 在接口中 Web3jRx

返回:

Observable that emits all new block hashes as new blocks are created on the blockchain

ethPendingTransactionHashObservable

public rx.Observable<java.lang.String> ethPendingTransactionHashObservable()

从接口复制的说明: Web3jRx

Create an Observable to emit pending transactions, i.e. those transactions that have been submitted by a node, but don't yet form part of a block (haven't been mined yet).

指定者:

ethPendingTransactionHashObservable 在接口中 Web3jRx

返回:

Observable to emit pending transaction hashes.

ethLogObservable

public rx.Observable<Log> ethLogObservable(EthFilter ethFilter)

从接口复制的说明: Web3jRx

Create an observable to filter for specific log events on the blockchain.

指定者:

ethLogObservable 在接口中 Web3jRx

参数:

ethFilter - filter criteria

返回:

Observable that emits all Log events matching the filter

transactionObservable

public rx.Observable<Transaction> transactionObservable()

从接口复制的说明: Web3jRx

Create an Observable to emit all new transactions as they are confirmed on the blockchain. i.e. they have been mined and are incorporated into a block.

指定者:

transactionObservable 在接口中 Web3jRx

返回:

Observable to emit new transactions on the blockchain

pendingTransactionObservable

public rx.Observable<Transaction> pendingTransactionObservable()

从接口复制的说明: Web3jRx

Create an Observable to emit all pending transactions that have yet to be placed into a block on the blockchain.

指定者:

pendingTransactionObservable 在接口中 Web3jRx

返回:

Observable to emit pending transactions

blockObservable

public rx.Observable<EthBlock> blockObservable(boolean fullTransactionObjects)

从接口复制的说明: Web3jRx

Create an Observable that emits newly created blocks on the blockchain.

指定者:

blockObservable 在接口中 Web3jRx

参数:

fullTransactionObjects - if true, provides transactions embedded in blocks, otherwise transaction hashes

返回:

Observable that emits all new blocks as they are added to the blockchain

replayBlocksObservable

public rx.Observable<EthBlock> replayBlocksObservable(DefaultBlockParameter startBlock,
                                                      DefaultBlockParameter endBlock,
                                                      boolean fullTransactionObjects)

从接口复制的说明: Web3jRx

Create an Observable that emits all blocks from the blockchain contained within the requested range.

指定者:

replayBlocksObservable 在接口中 Web3jRx

参数:

startBlock - block number to commence with

endBlock - block number to finish with

fullTransactionObjects - if true, provides transactions embedded in blocks, otherwise transaction hashes

返回:

Observable to emit these blocks

replayBlocksObservable

public rx.Observable<EthBlock> replayBlocksObservable(DefaultBlockParameter startBlock,
                                                      DefaultBlockParameter endBlock,
                                                      boolean fullTransactionObjects,
                                                      boolean ascending)

从接口复制的说明: Web3jRx

Create an Observable that emits all blocks from the blockchain contained within the requested range.

指定者:

replayBlocksObservable 在接口中 Web3jRx

参数:

startBlock - block number to commence with

endBlock - block number to finish with

fullTransactionObjects - if true, provides transactions embedded in blocks, otherwise transaction hashes

ascending - if true, emits blocks in ascending order between range, otherwise in descending order

返回:

Observable to emit these blocks

replayTransactionsObservable

public rx.Observable<Transaction> replayTransactionsObservable(DefaultBlockParameter startBlock,
                                                               DefaultBlockParameter endBlock)

从接口复制的说明: Web3jRx

Create an Observable that emits all transactions from the blockchain contained within the requested range.

指定者:

replayTransactionsObservable 在接口中 Web3jRx

参数:

startBlock - block number to commence with

endBlock - block number to finish with

返回:

Observable to emit these transactions in the order they appear in the blocks

catchUpToLatestBlockObservable

public rx.Observable<EthBlock> catchUpToLatestBlockObservable(DefaultBlockParameter startBlock,
                                                              boolean fullTransactionObjects,
                                                              rx.Observable<EthBlock> onCompleteObservable)

从接口复制的说明: Web3jRx

Create an Observable 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 Observable is invoked.

To automatically subscribe to new blocks, use Web3jRx.catchUpToLatestAndSubscribeToNewBlocksObservable(DefaultBlockParameter, boolean).

指定者:

catchUpToLatestBlockObservable 在接口中 Web3jRx

参数:

startBlock - the block number we wish to request from

fullTransactionObjects - if we require full Transaction objects to be provided in the EthBlock responses

onCompleteObservable - a subsequent Observable that we wish to run once we are caught up with the latest block

返回:

Observable to emit all requested blocks

catchUpToLatestBlockObservable

public rx.Observable<EthBlock> catchUpToLatestBlockObservable(DefaultBlockParameter startBlock,
                                                              boolean fullTransactionObjects)

从接口复制的说明: Web3jRx

Creates an Observable that emits all blocks from the requested block number to the most current. Once it has emitted the most current block, onComplete is called.

指定者:

catchUpToLatestBlockObservable 在接口中 Web3jRx

参数:

startBlock - the block number we wish to request from

fullTransactionObjects - if we require full Transaction objects to be provided in the EthBlock responses

返回:

Observable to emit all requested blocks

catchUpToLatestTransactionObservable

public rx.Observable<Transaction> catchUpToLatestTransactionObservable(DefaultBlockParameter startBlock)

从接口复制的说明: Web3jRx

Creates an Observable 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.

指定者:

catchUpToLatestTransactionObservable 在接口中 Web3jRx

参数:

startBlock - the block number we wish to request from

返回:

Observable to emit all requested transactions

catchUpToLatestAndSubscribeToNewBlocksObservable

public rx.Observable<EthBlock> catchUpToLatestAndSubscribeToNewBlocksObservable(DefaultBlockParameter startBlock,
                                                                                boolean fullTransactionObjects)

从接口复制的说明: Web3jRx

Creates an Observable 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.

指定者:

catchUpToLatestAndSubscribeToNewBlocksObservable 在接口中 Web3jRx

参数:

startBlock - the block number we wish to request from

fullTransactionObjects - if we require full Transaction objects to be provided in the EthBlock responses

返回:

Observable to emit all requested blocks and future

catchUpToLatestAndSubscribeToNewTransactionsObservable

public rx.Observable<Transaction> catchUpToLatestAndSubscribeToNewTransactionsObservable(DefaultBlockParameter startBlock)

从接口复制的说明: Web3jRx

As per Web3jRx.catchUpToLatestAndSubscribeToNewBlocksObservable(DefaultBlockParameter, boolean), except that all transactions contained within the blocks are emitted.

指定者:

catchUpToLatestAndSubscribeToNewTransactionsObservable 在接口中 Web3jRx

参数:

startBlock - the block number we wish to request from

返回:

Observable to emit all requested transactions and future

shutdown

public void shutdown()

从接口复制的说明: Web3j

Shutdowns a Web3j instance and closes opened resources.

指定者:

shutdown 在接口中 Web3j