diff options
| author |  Alexander Foremny <aforemny@posteo.de> | 2024-08-10 10:22:56 +0200 |
|---|---|---|
| committer | Alexander Foremny <aforemny@posteo.de> | 2024-08-10 10:22:56 +0200 |
| commit | e35752a7c7ecd36def983762d3417360c259cec3 (patch) | |
| tree | 89c1052a5230afe09992ceb4d7a715a1e9b85f3e /src/Data/Sensor.hs | |
| parent | 272b3ace747857729171780edae898819d211832 (diff) | |
drop monadic context from `LiveAggregate`
Diffstat (limited to 'src/Data/Sensor.hs')
| -rw-r--r-- | src/Data/Sensor.hs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/Data/Sensor.hs b/src/Data/Sensor.hs index 29ead27..787d919 100644 --- a/src/Data/Sensor.hs +++ b/src/Data/Sensor.hs @@ -350,7 +350,7 @@ deriving instance (MonadFail m) => MonadFail (SensorT m) deriving instance (Monad m) => MonadReader (SensorE (SensorT m)) (SensorT m) data SensorE m = SensorE - { liveAggregatesM :: TMVar (Map String (LiveAggregate m Dynamic)), + { liveAggregatesM :: TMVar (Map String (LiveAggregate Dynamic)), startAggregateT :: TQueue (AnyAggregate m), globalQueueT :: TChan (), globalTickM :: TMVar Int, @@ -366,7 +366,7 @@ instance (MonadUnliftIO m) => MonadSensor (SensorT m) where data AnyAggregate m where AnyAggregate :: forall m s a. (Aggregate m s a) => s -> AnyAggregate m -data LiveAggregate m a = LiveAggregate +data LiveAggregate a = LiveAggregate { valueT :: TVar (Maybe (Value a)), threadId :: ThreadId, spawnedAt :: Int |