From c0989001fbddc1b6e24783c3a4b8cb8775eab1fe Mon Sep 17 00:00:00 2001
From: wzy <wzy19931122ai@163.com>
Date: Sun, 06 Nov 2022 19:32:01 +0800
Subject: [PATCH] fix
---
src/main/java/cc/mrbird/febs/dapp/chain/EthUsdtContract.java | 18 ++++++++++++++++++
1 files changed, 18 insertions(+), 0 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/dapp/chain/EthUsdtContract.java b/src/main/java/cc/mrbird/febs/dapp/chain/EthUsdtContract.java
index 14658e9..955f75d 100644
--- a/src/main/java/cc/mrbird/febs/dapp/chain/EthUsdtContract.java
+++ b/src/main/java/cc/mrbird/febs/dapp/chain/EthUsdtContract.java
@@ -313,6 +313,24 @@
});
}
+ public Flowable<TransferEventResponse> transferEventFlowable(Web3j web3j, EthFilter filter) {
+ return web3j.ethLogFlowable(filter).map(new Function<Log, TransferEventResponse>() {
+ @Override
+ public TransferEventResponse apply(Log log) {
+ EventValuesWithLog eventValues = extractEventParametersWithLog(TRANSFER_EVENT, log);
+ TransferEventResponse typedResponse = new TransferEventResponse();
+ if(eventValues!=null){
+ typedResponse.log = log;
+ typedResponse.from = (String) eventValues.getIndexedValues().get(0).getValue();
+ typedResponse.to = (String) eventValues.getIndexedValues().get(1).getValue();
+ typedResponse.tokens = (BigInteger) eventValues.getNonIndexedValues().get(0).getValue();
+ }
+
+ return typedResponse;
+ }
+ });
+ }
+
public Flowable<TransferEventResponse> transferEventFlowable(DefaultBlockParameter startBlock, DefaultBlockParameter endBlock) {
EthFilter filter = new EthFilter(startBlock, endBlock, getContractAddress());
filter.addSingleTopic(EventEncoder.encode(TRANSFER_EVENT));
--
Gitblit v1.9.1