Skip to content
Snippets Groups Projects
Commit 150df6c3 authored by Jens Nolte's avatar Jens Nolte
Browse files

Remove more old Observable code

parent 8e9478b4
No related branches found
No related tags found
No related merge requests found
...@@ -18,8 +18,6 @@ module Quasar.Observable ( ...@@ -18,8 +18,6 @@ module Quasar.Observable (
--observeWhile, --observeWhile,
--observeWhile_, --observeWhile_,
--observeBlocking, --observeBlocking,
--fnObservable,
--synchronousFnObservable,
---- * Helper types ---- * Helper types
--ObservableCallback, --ObservableCallback,
...@@ -396,38 +394,6 @@ stateObservableVar (ObservableVar var registry) f = ensureQuasarSTM do ...@@ -396,38 +394,6 @@ stateObservableVar (ObservableVar var registry) f = ensureQuasarSTM do
pure result 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 --newtype FailedObservable v = FailedObservable SomeException
--instance IsRetrievable v (FailedObservable v) where --instance IsRetrievable v (FailedObservable v) where
-- retrieve (FailedObservable ex) = liftIO $ throwIO ex -- retrieve (FailedObservable ex) = liftIO $ throwIO ex
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment