块和交易过滤器
接收所有新块把它们添加到区块链(false参数指定我们只需要块就ok,而不需要嵌入交易):
Subscription subscription = web3j.blockObservable(false).subscribe(block -> {
...
});
接收所有新交易,把它们添加到块链:
Subscription subscription = web3j.transactionObservable().subscribe(tx -> {
...
});
接收所有待提交交易并提交到网络(即在它们被分组在一起之前):
Subscription subscription = web3j.pendingTransactionObservable().subscribe(tx -> {
...
});
不再需要的时候取消订阅unsubscribe
:
subscription.unsubscribe();
另外还提供了其他回调,它们简单地提供了块或交易hash,这些细节涉及Web3JRX接口。