From e38d5c1a099859b891c434ba16a018dda137c404 Mon Sep 17 00:00:00 2001 From: command-line Date: Sun, 21 Apr 2024 13:19:24 +0100 Subject: [PATCH] update functional hello world --- .../example/functional/helloworld/Main.java | 26 +++++++++---------- 1 file changed, 13 insertions(+), 13 deletions(-) diff --git a/functional-helloworld/src/main/java/com/fluxtion/example/functional/helloworld/Main.java b/functional-helloworld/src/main/java/com/fluxtion/example/functional/helloworld/Main.java index dc94f51..c3f1ac9 100644 --- a/functional-helloworld/src/main/java/com/fluxtion/example/functional/helloworld/Main.java +++ b/functional-helloworld/src/main/java/com/fluxtion/example/functional/helloworld/Main.java @@ -16,27 +16,27 @@ */ public class Main { public static void main(String[] args) { - //builds the EventProcessor - EventProcessor eventProcessor = Fluxtion.interpret(cfg -> { + //build the EventProcessor and initialise it + var eventProcessor = Fluxtion.interpret(cfg -> { var data1Stream = DataFlow.subscribe(Data1.class) - .console("rcvd -> {}") - .mapToDouble(Data1::value); + .mapToDouble(Data1::value) + .defaultValue(0); DataFlow.subscribe(Data2.class) - .console("rcvd -> {}") .mapToDouble(Data2::value) + .defaultValue(0) .mapBiFunction(Double::sum, data1Stream) + .console("sum:{}") .filter(d -> d > 100) - .console("OUT: sum {} > 100"); + .console("WARNING DataSumCalculator value is greater than 100 sum = {}"); }); - //init and send events eventProcessor.init(); - //no output < 100 - eventProcessor.onEvent(new Data1(20.5)); - //no output < 100 - eventProcessor.onEvent(new Data2(63)); - //output > 100 - log to console - eventProcessor.onEvent(new Data1(56.8)); + + //send events + eventProcessor.onEvent(new Data1(34)); + eventProcessor.onEvent(new Data2(52.1)); + eventProcessor.onEvent(new Data1(105));//should create a breach warning + eventProcessor.onEvent(new Data1(12.4)); } public record Data1(double value) {