Web.Dependencies.Sparrow.Client.Types

Internal Machinery

type RegisteredTopicSubscriptions m = TMapMVar Topic (Value -> m (), m ())

registerSubscription :: Env m -> Topic -> (Value -> m ()) -> m () -> STM ()

removeSubscription :: Env m -> Topic -> STM ()

callReject :: MonadIO m => Env m -> Topic -> m ()

callOnReceive :: MonadIO m => Env m -> Topic -> Value -> m ()

Context

newtype SparrowClientT m a

Constructors

SparrowClientT

Fields

• runSparrowClientT :: ReaderT (Env m) m a

Instances

MonadTrans SparrowClientT

Methods

lift :: Monad m => m a -> SparrowClientT m a

MonadWriter w m => MonadWriter w (SparrowClientT m)

Methods

writer :: (a, w) -> SparrowClientT m a

tell :: w -> SparrowClientT m ()

listen :: SparrowClientT m a -> SparrowClientT m (a, w)

pass :: SparrowClientT m (a, w -> w) -> SparrowClientT m a

MonadState s m => MonadState s (SparrowClientT m)

Methods

get :: SparrowClientT m s

put :: s -> SparrowClientT m ()

state :: (s -> (a, s)) -> SparrowClientT m a

MonadReader r m => MonadReader r (SparrowClientT m)

Methods

ask :: SparrowClientT m r

local :: (r -> r) -> SparrowClientT m a -> SparrowClientT m a

reader :: (r -> a) -> SparrowClientT m a

Monad m => Monad (SparrowClientT m)

Methods

(>>=) :: SparrowClientT m a -> (a -> SparrowClientT m b) -> SparrowClientT m b

(>>) :: SparrowClientT m a -> SparrowClientT m b -> SparrowClientT m b

return :: a -> SparrowClientT m a

fail :: String -> SparrowClientT m a

Functor m => Functor (SparrowClientT m)

Methods

fmap :: (a -> b) -> SparrowClientT m a -> SparrowClientT m b

(<$) :: a -> SparrowClientT m b -> SparrowClientT m a

Applicative m => Applicative (SparrowClientT m)

Methods

pure :: a -> SparrowClientT m a

(<*>) :: SparrowClientT m (a -> b) -> SparrowClientT m a -> SparrowClientT m b

liftA2 :: (a -> b -> c) -> SparrowClientT m a -> SparrowClientT m b -> SparrowClientT m c

(*>) :: SparrowClientT m a -> SparrowClientT m b -> SparrowClientT m b

(<*) :: SparrowClientT m a -> SparrowClientT m b -> SparrowClientT m a

MonadIO m => MonadIO (SparrowClientT m)

Methods

liftIO :: IO a -> SparrowClientT m a

MonadThrow m => MonadThrow (SparrowClientT m)

Methods

throwM :: Exception e => e -> SparrowClientT m a

MonadCatch m => MonadCatch (SparrowClientT m)

Methods

catch :: Exception e => SparrowClientT m a -> (e -> SparrowClientT m a) -> SparrowClientT m a

MonadMask m => MonadMask (SparrowClientT m)

Methods

mask :: ((forall a. SparrowClientT m a -> SparrowClientT m a) -> SparrowClientT m b) -> SparrowClientT m b

uninterruptibleMask :: ((forall a. SparrowClientT m a -> SparrowClientT m a) -> SparrowClientT m b) -> SparrowClientT m b

generalBracket :: SparrowClientT m a -> (a -> ExitCase b -> SparrowClientT m c) -> (a -> SparrowClientT m b) -> SparrowClientT m (b, c)

data Env m

Constructors

Env

Fields

• envSendDelta :: WSIncoming (WithTopic Value) -> m ()
• envSendInit :: Topic -> Value -> m (Maybe Value)
• envSubscriptions :: !(RegisteredTopicSubscriptions m)

ask' :: Applicative m => SparrowClientT m (Env m)

Exceptions

data SparrowClientException

Constructors

InitOutFailed

InitOutDecodingError String

DeltaOutDecodingError String

InitOutHTTPError

UnexpectedAddedTopic Topic

UnexpectedRemovedTopic Topic

NetworkingDecodingError String

Instances

Show SparrowClientException

Methods

showsPrec :: Int -> SparrowClientException -> ShowS

show :: SparrowClientException -> String

showList :: [SparrowClientException] -> ShowS

Generic SparrowClientException

Associated Types

type Rep SparrowClientException :: * -> *

Methods

from :: SparrowClientException -> Rep SparrowClientException x

to :: Rep SparrowClientException x -> SparrowClientException

Exception SparrowClientException

Methods

toException :: SparrowClientException -> SomeException

fromException :: SomeException -> Maybe SparrowClientException

displayException :: SparrowClientException -> String

type Rep SparrowClientException

type Rep SparrowClientException = D1 * (MetaData "SparrowClientException" "Web.Dependencies.Sparrow.Client.Types" "sparrow-0.0.1.2-E3S88fH87X7KfYDlvxyZIs" False) ((:+:) * ((:+:) * (C1 * (MetaCons "InitOutFailed" PrefixI False) (U1 *)) ((:+:) * (C1 * (MetaCons "InitOutDecodingError" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * String))) (C1 * (MetaCons "DeltaOutDecodingError" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * String))))) ((:+:) * ((:+:) * (C1 * (MetaCons "InitOutHTTPError" PrefixI False) (U1 *)) (C1 * (MetaCons "UnexpectedAddedTopic" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Topic)))) ((:+:) * (C1 * (MetaCons "UnexpectedRemovedTopic" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Topic))) (C1 * (MetaCons "NetworkingDecodingError" PrefixI False) (S1 * (MetaSel (Nothing Symbol) NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * String))))))