Received: 1 Received: 2 Received: 3 Exception in thread "main" java.lang.ArithmeticException: / by zero at DebugExample.lambda$main$0(DebugExample.java:12) at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:120) at reactor.core.publisher.FluxJust$WeakScalarSubscription.request(FluxJust.java:91) at reactor.core.publisher.FluxMap$MapSubscriber.request(FluxMap.java:155) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.set(Operators.java:1266) at reactor.core.publisher.FluxMap.onSubscribe(FluxMap.java:59) at reactor.core.publisher.FluxJust.subscribe(FluxJust.java:68) at reactor.core.publisher.FluxMap.subscribe(FluxMap.java:44) at reactor.core.publisher.Flux.subscribe(Flux.java:9117) at reactor.core.publisher.Flux.subscribe(Flux.java:9091) at DebugExample.main(DebugExample.java:14)
Received: 1 Received: 2 Received: 3 Error: java.lang.ArithmeticException: / by zero at reactor.core.publisher.Operators.onErrorDropped(Operators.java:197) Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: | onSubscribe([Synchronous Fuseable] FluxMapFuseable.MapFuseableSubscriber) | Flux.map(Map.java:95) | Flux.map(Map.java:92) | DebugExample.main(DebugExample.java:15) | onAssembly(FluxMapFuseable) | Flux.map(Map.java:95) | Flux.map(Map.java:92) | DebugExample.main(DebugExample.java:15) | request(unbounded) at reactor.core.publisher.FluxOnAssembly.onAssembly(FluxOnAssembly.java:482) at reactor.core.publisher.FluxMapFuseable.subscribe(FluxMapFuseable.java:64) at reactor.core.publisher.Flux.subscribe(Flux.java:9065) at reactor.core.publisher.Flux.subscribe(Flux.java:9039) at DebugExample.main(DebugExample.java:14) Suppressed: java.lang.ArithmeticException: / by zero at reactor.core.publisher.Operators.onErrorDropped(Operators.java:197) Suppressed: java.lang.ArithmeticException: / by zero at reactor.core.publisher.Operators.onErrorDropped(Operators.java:197) Suppressed: java.lang.ArithmeticException: / by zero at reactor.core.publisher.Operators.onErrorDropped(Operators.java:197) Suppressed: java.lang.ArithmeticException: / by zero at reactor.core.publisher.Operators.onErrorDropped(Operators.java:197) Suppressed: java.lang.ArithmeticException: / by zero at reactor.core.publisher.Operators.onErrorDropped(Operators.java:197) Suppressed: java.lang.ArithmeticException: / by zero at reactor.core.publisher.Operators.onErrorDropped(Operators.java:197) Suppressed: java.lang.ArithmeticException: / by zero at reactor.core.publisher.Operators.onErrorDropped(Operators.java:197) Suppressed: java.lang.ArithmeticException: / by zero at reactor.core.publisher.Operators.onErrorDropped(Operators.java:197) at reactor.core.publisher.FluxOnAssembly.onAssembly(FluxOnAssembly.java:482) at reactor.core.publisher.FluxMapFuseable.subscribe(FluxMapFuseable.java:64) at reactor.core.publisher.Flux.subscribe(Flux.java:9065) at reactor.core.publisher.Flux.subscribe(Flux.java:9039) at DebugExample.main(DebugExample.java:14)