From 1f82195d68af01f8c60485361334434cea4cf7fa Mon Sep 17 00:00:00 2001
From: Andrea Burattin <andrea.burattin@gmail.com>
Date: Fri, 4 Mar 2022 11:29:09 +0100
Subject: [PATCH] Added missing onComplete
---
src/main/java/beamline/sources/CSVLogSource.java | 1 +
src/main/java/beamline/sources/XesLogSource.java | 1 +
2 files changed, 2 insertions(+)
diff --git a/src/main/java/beamline/sources/CSVLogSource.java b/src/main/java/beamline/sources/CSVLogSource.java
index a9ff1fc..85a09f9 100644
--- a/src/main/java/beamline/sources/CSVLogSource.java
+++ b/src/main/java/beamline/sources/CSVLogSource.java
@@ -91,6 +91,7 @@ public class CSVLogSource implements XesSource {
eventWrapper.add(newEvent);
emitter.onNext(eventWrapper);
}
+ emitter.onComplete();
}
});
}
diff --git a/src/main/java/beamline/sources/XesLogSource.java b/src/main/java/beamline/sources/XesLogSource.java
index 5cce709..d906900 100644
--- a/src/main/java/beamline/sources/XesLogSource.java
+++ b/src/main/java/beamline/sources/XesLogSource.java
@@ -67,6 +67,7 @@ public class XesLogSource implements XesSource {
for (XTrace wrapper : events) {
emitter.onNext(wrapper);
}
+ emitter.onComplete();
}
});
}
--
GitLab