Removed questionable subscribeOn() (#271, #290)

home-climate-control · Oct 8, 2023 · 883bd0c · 883bd0c
1 parent d74dade
commit 883bd0c
Showing 1 changed file with 0 additions and 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
@@ -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<Signal<Double, Void>> 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<Signal<Double, Void>> ambientFlux) {
                 .subscribe();
 
         ambientFlux
-                .subscribeOn(Schedulers.boundedElastic())
                 .doOnNext(this::recordAmbient)
 
                 // VT: NOTE: Careful when testing, this will consume everything thrown at it immediately