| | |
|---|
| | | EthUsdtContract ethUsdtContract = wssContract(chain.getPrivateKey(), chain.getContractAddress(), web3j); |
|---|
| | | EthFilter filter = getFilter(startBlock, startBlock, chain.getContractAddress()); |
|---|
| | | Flowable<EthUsdtContract.TransferEventResponse> eventFlowable = ethUsdtContract.transferEventFlowable(filter); |
|---|
| | | |
|---|
| | | // 判断websocket是否连接成功 |
|---|
| | | if (!webSocketClient.isOpen()) { |
|---|
| | | log.error("WebSocket连接失败"); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | // 订阅事件流，将事件编译和处理放到单独的线程中执行 |
|---|
| | | Disposable subscribe = eventFlowable.observeOn(Schedulers.from(executor)) |
|---|
| | | .subscribe(event::compile, error -> { |
|---|
