From 150df6c37e3aa0d165bb159b19958785fd2da294 Mon Sep 17 00:00:00 2001 From: Jens Nolte <git@queezle.net> Date: Sun, 13 Mar 2022 16:21:42 +0100 Subject: [PATCH] Remove more old Observable code --- src/Quasar/Observable.hs | 34 ---------------------------------- 1 file changed, 34 deletions(-) diff --git a/src/Quasar/Observable.hs b/src/Quasar/Observable.hs index e156c6b..1b4c2fc 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 -- GitLab