From b928431ec47ed340b9d122b9a5e8266776512318 Mon Sep 17 00:00:00 2001
From: Andrea Burattin <andrea.burattin@gmail.com>
Date: Fri, 18 Nov 2022 14:07:45 +0100
Subject: [PATCH] Sleepy bug-fix
---
.../java/beamline/models/algorithms/StreamMiningAlgorithm.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/src/main/java/beamline/models/algorithms/StreamMiningAlgorithm.java b/src/main/java/beamline/models/algorithms/StreamMiningAlgorithm.java
index 8bb7636..8528ba0 100644
--- a/src/main/java/beamline/models/algorithms/StreamMiningAlgorithm.java
+++ b/src/main/java/beamline/models/algorithms/StreamMiningAlgorithm.java
@@ -82,7 +82,7 @@ public abstract class StreamMiningAlgorithm<T extends Response> extends RichFlat
protected T process(BEvent event) {
try {
long value = 1;
- if (processedEvents == null || processedEvents.value() != null) {
+ if (processedEvents != null && processedEvents.value() != null) {
value = processedEvents.value() + 1;
}
processedEvents.update(value);
--
GitLab