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

Remove ObservableReconnecting


Co-authored-by: default avatarJan Beinke <git@janbeinke.com>
parent 18cffd79
No related branches found
No related tags found
No related merge requests found
...@@ -48,22 +48,18 @@ import System.IO (fixIO) ...@@ -48,22 +48,18 @@ import System.IO (fixIO)
data ObservableMessage a data ObservableMessage a
= ObservableUpdate a = ObservableUpdate a
| ObservableLoading | ObservableLoading
| ObservableReconnecting SomeException
| ObservableNotAvailable SomeException | ObservableNotAvailable SomeException
deriving stock (Show, Generic) deriving stock (Show, Generic)
instance Functor ObservableMessage where instance Functor ObservableMessage where
fmap fn (ObservableUpdate x) = ObservableUpdate (fn x) fmap fn (ObservableUpdate x) = ObservableUpdate (fn x)
fmap _ ObservableLoading = ObservableLoading fmap _ ObservableLoading = ObservableLoading
fmap _ (ObservableReconnecting ex) = ObservableReconnecting ex
fmap _ (ObservableNotAvailable ex) = ObservableNotAvailable ex fmap _ (ObservableNotAvailable ex) = ObservableNotAvailable ex
instance Applicative ObservableMessage where instance Applicative ObservableMessage where
pure = ObservableUpdate pure = ObservableUpdate
liftA2 _ (ObservableNotAvailable ex) _ = ObservableNotAvailable ex liftA2 _ (ObservableNotAvailable ex) _ = ObservableNotAvailable ex
liftA2 _ _ (ObservableNotAvailable ex) = ObservableNotAvailable ex liftA2 _ _ (ObservableNotAvailable ex) = ObservableNotAvailable ex
liftA2 _ (ObservableReconnecting ex) _ = ObservableReconnecting ex
liftA2 _ _ (ObservableReconnecting ex) = ObservableReconnecting ex
liftA2 _ ObservableLoading _ = ObservableLoading liftA2 _ ObservableLoading _ = ObservableLoading
liftA2 _ _ ObservableLoading = ObservableLoading liftA2 _ _ ObservableLoading = ObservableLoading
liftA2 fn (ObservableUpdate x) (ObservableUpdate y) = ObservableUpdate (fn x y) liftA2 fn (ObservableUpdate x) (ObservableUpdate y) = ObservableUpdate (fn x y)
...@@ -196,7 +192,6 @@ instance IsObservable r (BindObservable r) where ...@@ -196,7 +192,6 @@ instance IsObservable r (BindObservable r) where
where where
outerMessageHandler key (ObservableUpdate x) = observe (fn x) (innerCallback key) outerMessageHandler key (ObservableUpdate x) = observe (fn x) (innerCallback key)
outerMessageHandler key (ObservableLoading) = noDisposable <$ callback ObservableLoading outerMessageHandler key (ObservableLoading) = noDisposable <$ callback ObservableLoading
outerMessageHandler key (ObservableReconnecting ex) = noDisposable <$ callback (ObservableReconnecting ex)
outerMessageHandler key (ObservableNotAvailable ex) = noDisposable <$ callback (ObservableNotAvailable ex) outerMessageHandler key (ObservableNotAvailable ex) = noDisposable <$ callback (ObservableNotAvailable ex)
innerCallback :: Unique -> ObservableMessage r -> IO () innerCallback :: Unique -> ObservableMessage r -> IO ()
......
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