| | |
|---|
| | | return web3j.ethLogFlowable(filter).map(new Function<Log, CoinRewardEventResponse>() { |
|---|
| | | @Override |
|---|
| | | public CoinRewardEventResponse apply(Log log) { |
|---|
| | | // final List<String> topics = log.getTopics(); |
|---|
| | | // String encodedEventSignature = EventEncoder.encode(COINREWARD_EVENT); |
|---|
| | | // if (topics == null || topics.size() == 0 || !topics.get(0).equals(encodedEventSignature)) { |
|---|
| | | // return null; |
|---|
| | | // } |
|---|
| | | // |
|---|
| | | // List<Type> indexedValues = new ArrayList<>(); |
|---|
| | | // List<Type> nonIndexedValues = |
|---|
| | | // FunctionReturnDecoder.decode(log.getData(), COINREWARD_EVENT.getNonIndexedParameters()); |
|---|
| | | // |
|---|
| | | // List<TypeReference<Type>> indexedParameters = COINREWARD_EVENT.getIndexedParameters(); |
|---|
| | | // for (int i = 0; i < indexedParameters.size(); i++) { |
|---|
| | | // Type value = |
|---|
| | | // FunctionReturnDecoder.decodeIndexedValue( |
|---|
| | | // topics.get(i + 1), indexedParameters.get(i)); |
|---|
| | | // indexedValues.add(value); |
|---|
| | | // } |
|---|
| | | // final EventValues eventValues = new EventValues(indexedValues, nonIndexedValues); |
|---|
| | | EventValuesWithLog eventValues = extractEventParametersWithLog(COINREWARD_EVENT, log); |
|---|
| | | CoinRewardEventResponse typedResponse = new CoinRewardEventResponse(); |
|---|
| | | if(eventValues!=null){ |
|---|
