diff --git a/src/Quasar/Network/Runtime/Observable.hs b/src/Quasar/Network/Runtime/Observable.hs index 02f91515d6934caa396629273b6da1d9c66891c8..8391e3821f0fd8fe2a0174a90c07213326ea8f78 100644 --- a/src/Quasar/Network/Runtime/Observable.hs +++ b/src/Quasar/Network/Runtime/Observable.hs @@ -8,11 +8,11 @@ import Quasar.Observable import Quasar.Prelude newObservableStub - :: forall v. Binary v => - (forall m. MonadIO m => m (Stream Void v)) - -> (forall m. MonadIO m => m (Awaitable v)) + :: forall v. Binary v + => (forall m. MonadIO m => m (Awaitable v)) + -> (forall m. MonadIO m => m (Stream Void v)) -> IO (Observable v) -newObservableStub startObserveRequest startRetrieveRequest = pure uncachedObservable -- TODO cache +newObservableStub startRetrieveRequest startObserveRequest = pure uncachedObservable -- TODO cache where uncachedObservable :: Observable v uncachedObservable = fnObservable observeFn retrieveFn