Added missing onComplete

src/main/java/beamline/sources/CSVLogSource.java

@@ -91,6 +91,7 @@ public class CSVLogSource implements XesSource {
 					eventWrapper.add(newEvent);
 					emitter.onNext(eventWrapper);
 				}
+				emitter.onComplete();
 			}
 		});
 	}

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();
 			}
 		});
 	}