diff options
Diffstat (limited to 'src/Data')
| -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 |