diff --git a/src/Quasar/Observable.hs b/src/Quasar/Observable.hs index e156c6bd96f227e44799f12f302dc1aac8f83c4b..1b4c2fc3d6639ce4d872c274baec22c4bf36dd22 100644 --- a/src/Quasar/Observable.hs +++ b/src/Quasar/Observable.hs @@ -18,8 +18,6 @@ module Quasar.Observable ( --observeWhile, --observeWhile_, --observeBlocking, - --fnObservable, - --synchronousFnObservable, ---- * Helper types --ObservableCallback, @@ -396,38 +394,6 @@ stateObservableVar (ObservableVar var registry) f = ensureQuasarSTM do pure result ---data FnObservable v = FnObservable { --- retrieveFn :: ResourceManagerIO (Future v), --- observeFn :: (ObservableState v -> ResourceManagerIO ()) -> ResourceManagerIO () ---} ---instance IsRetrievable v (FnObservable v) where --- retrieve FnObservable{retrieveFn} = liftResourceManagerIO retrieveFn ---instance IsObservable v (FnObservable v) where --- observe FnObservable{observeFn} callback = liftResourceManagerIO $ observeFn callback --- mapObservable f FnObservable{retrieveFn, observeFn} = Observable $ FnObservable { --- retrieveFn = f <<$>> retrieveFn, --- observeFn = \listener -> observeFn (listener . fmap f) --- } --- ----- | Implement an Observable by directly providing functions for `retrieve` and `subscribe`. ---fnObservable --- :: ((ObservableState v -> ResourceManagerIO ()) -> ResourceManagerIO ()) --- -> ResourceManagerIO (Future v) --- -> Observable v ---fnObservable observeFn retrieveFn = toObservable FnObservable{observeFn, retrieveFn} --- ----- | Implement an Observable by directly providing functions for `retrieve` and `subscribe`. ---synchronousFnObservable --- :: forall v. --- ((ObservableState v -> ResourceManagerIO ()) -> ResourceManagerIO ()) --- -> IO v --- -> Observable v ---synchronousFnObservable observeFn synchronousRetrieveFn = fnObservable observeFn retrieveFn --- where --- retrieveFn :: ResourceManagerIO (Future v) --- retrieveFn = liftIO $ pure <$> synchronousRetrieveFn - - --newtype FailedObservable v = FailedObservable SomeException --instance IsRetrievable v (FailedObservable v) where -- retrieve (FailedObservable ex) = liftIO $ throwIO ex