fix termination condition

Author: mriccobene

pkg/coordinator/tasks/tx_pool_latency_analysis/task.go

@@ -253,7 +253,7 @@ func (t *Task) Execute(ctx context.Context) error {
 				}
 			}
 
-			if receivedEvents == totNumberOfTxes {
+			if receivedEvents >= totNumberOfTxes {
 				t.logger.Infof("Reading of p2p events finished")
 				return
 			}

pkg/coordinator/tasks/tx_pool_throughput_analysis/task.go

@@ -252,7 +252,7 @@ func (t *Task) Execute(ctx context.Context) error {
 				}
 			}
 
-			if receivedEvents == totNumberOfTxes {
+			if receivedEvents >= totNumberOfTxes {
 				t.logger.Infof("Reading of p2p events finished")
 				return
 			}