diff --git a/Framework/NethereumWorkflow/NethereumInteraction.cs b/Framework/NethereumWorkflow/NethereumInteraction.cs index cad61334..7e16e451 100644 --- a/Framework/NethereumWorkflow/NethereumInteraction.cs +++ b/Framework/NethereumWorkflow/NethereumInteraction.cs @@ -114,7 +114,7 @@ namespace NethereumWorkflow var p = web3.Processing.Logs.CreateProcessor( action: logs.Add, minimumBlockConfirmations: 1, - criteria: l => l.Address == address + criteria: l => l.IsLogForEvent() ); var from = new BlockParameter(fromBlockNumber); @@ -122,7 +122,6 @@ namespace NethereumWorkflow var ct = new CancellationTokenSource().Token; Time.Wait(p.ExecuteAsync(toBlockNumber: to.BlockNumber, cancellationToken: ct, startAtBlockNumberIfNotProcessed: from.BlockNumber)); - return logs .Where(l => l.IsLogForEvent()) .Select(l => l.DecodeEvent())