fix: stop ticks when there are no more subscribers

metacosm · Dec 22, 2023 · cf5f854 · cf5f854
1 parent 90df2ff
commit cf5f854
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/server/src/main/java/io/github/metacosm/power/PowerMeasurer.java b/server/src/main/java/io/github/metacosm/power/PowerMeasurer.java
@@ -2,14 +2,12 @@
 
 import io.github.metacosm.power.sensors.Measures;
 import io.github.metacosm.power.sensors.PowerSensor;
-import io.github.metacosm.power.sensors.RegisteredPID;
 import io.smallrye.mutiny.Multi;
 import io.smallrye.mutiny.infrastructure.Infrastructure;
 import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.inject.Inject;
 
 import java.time.Duration;
-import java.util.Map;
 
 @ApplicationScoped
 public class PowerMeasurer {
@@ -30,7 +28,9 @@ public Multi<SensorMeasure> startTracking(String pid) throws Exception {
             periodicSensorCheck = Multi.createFrom().ticks()
                     .every(Duration.ofMillis(SAMPLING_FREQUENCY_IN_MILLIS))
                     .map(sensor::update)
-                    .broadcast().toAllSubscribers()
+                    .broadcast()
+                    .withCancellationAfterLastSubscriberDeparture()
+                    .toAtLeast(1)
                     .runSubscriptionOn(Infrastructure.getDefaultWorkerPool());
         }
         final var registeredPID = sensor.register(parsedPID);