Moved bugfix (rev. 71a8438) into a better place (#238, #271, #290)

dz3r-model/src/main/java/net/sf/dz3r/model/Zone.java

@@ -200,7 +200,9 @@ public Flux<Signal<ZoneStatus, String>> compute(Flux<Signal<Double, String>> in)
         // - the feedback, repeats the last sensor reading upon changing zone settings and forces a new signal to be emitted here
 
         // Record the signal so the feedback flux can pick it up
-        var recorded = in.doOnNext(this::recordSignal);
+        var recorded = in
+                .doOnNext(this::recordSignal)
+                .doOnComplete(feedbackSink::tryEmitComplete);
 
         var combined = Flux.merge(recorded, feedbackFlux);
 
@@ -300,8 +302,6 @@ public void close() throws Exception {
                 economizer.close();
             }
 
-            feedbackSink.tryEmitComplete();
-
         } finally {
             logger.info("Shut down: {}", getAddress());
             ThreadContext.pop();