library examples

v12technology · Apr 28, 2024 · 244dfe5 · 244dfe5
1 parent 4160b5f
commit 244dfe5
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/...les/integration/src/main/java/com/fluxtion/example/reference/integration/SinkExample.java b/...les/integration/src/main/java/com/fluxtion/example/reference/integration/SinkExample.java
@@ -11,13 +11,17 @@ public static void main(String[] args) {
         var processor = Fluxtion.interpret(cfg ->
                 DataFlow.subscribeToIntSignal("myIntSignal")
                         .mapToObj(d -> "intValue:" + d)
-                        .sink("mySink"));
+                        .sink("mySink")//CREATE A SINK IN THE PROCESSOR
+        );
         processor.init();
+
+        //ADDING A SINK
         processor.addSink("mySink", (Consumer<String>) System.out::println);
 
         processor.publishSignal("myIntSignal", 10);
         processor.publishSignal("myIntSignal", 256);
 
+        //REMOVING A SINK
         processor.removeSink("mySink");
         processor.publishSignal("myIntSignal", 512);
     }