From 883bd0c50bb61fdc3fd5a0fc89a2436732437cdb Mon Sep 17 00:00:00 2001 From: Vadim Tkachenko Date: Sat, 7 Oct 2023 22:53:57 -0700 Subject: [PATCH] Removed questionable subscribeOn() (#271, #290) --- .../sf/dz3r/device/actuator/economizer/AbstractEconomizer.java | 3 --- 1 file changed, 3 deletions(-) diff --git a/dz3r-model/src/main/java/net/sf/dz3r/device/actuator/economizer/AbstractEconomizer.java b/dz3r-model/src/main/java/net/sf/dz3r/device/actuator/economizer/AbstractEconomizer.java index 5b054320e..82e8e9dac 100644 --- a/dz3r-model/src/main/java/net/sf/dz3r/device/actuator/economizer/AbstractEconomizer.java +++ b/dz3r-model/src/main/java/net/sf/dz3r/device/actuator/economizer/AbstractEconomizer.java @@ -19,7 +19,6 @@ import org.apache.logging.log4j.ThreadContext; import reactor.core.publisher.Flux; import reactor.core.publisher.FluxSink; -import reactor.core.scheduler.Schedulers; import java.util.concurrent.CountDownLatch; @@ -121,7 +120,6 @@ protected final void initFluxes(Flux> ambientFlux) { // Just get the (indoor, ambient) pair flux with no nulls or errors var stage1 = Flux .create(this::connectCombined) - .subscribeOn(Schedulers.boundedElastic()) .doOnNext(pair -> logger.trace("{}: raw indoor={}, ambient={}", getAddress(), pair.getLeft(), pair.getRight())) .filter(pair -> pair.getLeft() != null && pair.getRight() != null) .filter(pair -> !pair.getLeft().isError() && !pair.getRight().isError()) @@ -142,7 +140,6 @@ protected final void initFluxes(Flux> ambientFlux) { .subscribe(); ambientFlux - .subscribeOn(Schedulers.boundedElastic()) .doOnNext(this::recordAmbient) // VT: NOTE: Careful when testing, this will consume everything thrown at it immediately