From c40ff373e4d8f7cf7b6de98992bf983e624e59f3 Mon Sep 17 00:00:00 2001 From: Jens Nolte <git@queezle.net> Date: Sun, 29 Aug 2021 23:37:37 +0200 Subject: [PATCH] Add asyncObserve_ Co-authored-by: Jan Beinke <git@janbeinke.com> --- src/Quasar/Observable.hs | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/Quasar/Observable.hs b/src/Quasar/Observable.hs index 5efc542..7b817fa 100644 --- a/src/Quasar/Observable.hs +++ b/src/Quasar/Observable.hs @@ -9,6 +9,7 @@ module Quasar.Observable ( Observable(..), ObservableMessage(..), asyncObserve, + asyncObserve_, -- * ObservableVar ObservableVar, @@ -120,6 +121,9 @@ class IsRetrievable v o => IsObservable v o | o -> v where asyncObserve :: IsObservable v o => MonadAsync m => o -> (ObservableMessage v -> m ()) -> m Disposable asyncObserve observable callback = toDisposable <$> async (observe observable callback) +asyncObserve_ :: IsObservable v o => MonadAsync m => o -> (ObservableMessage v -> m ()) -> m () +asyncObserve_ observable callback = async_ (observe observable callback) + data ObserveWhileCompleted = ObserveWhileCompleted deriving (Eq, Show) -- GitLab