From 7d0efb1f72d64265b3e771daed3d22447019ec1f Mon Sep 17 00:00:00 2001 From: Pieter Bonte Date: Fri, 10 Dec 2021 14:14:19 +0100 Subject: [PATCH] Removes duplicate reported answers --- .../streamreasoning/rsp4j/abstraction/ContinuousProgram.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/abstraction/src/main/java/org/streamreasoning/rsp4j/abstraction/ContinuousProgram.java b/abstraction/src/main/java/org/streamreasoning/rsp4j/abstraction/ContinuousProgram.java index 88eab4d3..2dc462d7 100644 --- a/abstraction/src/main/java/org/streamreasoning/rsp4j/abstraction/ContinuousProgram.java +++ b/abstraction/src/main/java/org/streamreasoning/rsp4j/abstraction/ContinuousProgram.java @@ -102,7 +102,7 @@ public void update(Observable o, Object arg) { if (task.getAggregations().isEmpty()) { Stream r2rResult = eval(now); Stream output = r2s.getR2sOperator().eval(r2rResult, now); - output.forEach(out->{System.out.println(out);outputStream.put(out,now);}); + output.forEach(out->{outputStream.put(out,now);}); } else { handleAggregations(task, r2s, now); }