Safe Haskell	None
Language	Haskell2010

Data.Morpheus.Types.Internal.Subscription

Synopsis

connect :: MonadIO m => m (Input WS)
disconnect :: Scope WS e m -> Input WS -> m ()
connectionThread :: MonadUnliftIO m => App e m -> Scope WS e m -> m ()
runStreamWS :: Monad m => Scope WS e m -> Stream WS e m -> m ()
runStreamHTTP :: Monad m => Scope HTTP e m -> Stream HTTP e m -> m GQLResponse
data Scope (api :: API) event (m :: * -> *) where
- ScopeHTTP :: {..} -> Scope HTTP event m
- ScopeWS :: {..} -> Scope WS event m
data Input (api :: API) where
- Init :: ID -> Input WS
- Request :: GQLRequest -> Input HTTP
type WS = WS
type HTTP = HTTP
acceptApolloRequest :: MonadIO m => PendingConnection -> m Connection
publish :: (Monad m, Eq channel) => Event channel content -> ClientConnectionStore (Event channel content) m -> m ()
data Store e m = Store {
- readStore :: m (ClientConnectionStore e m)
- writeStore :: (ClientConnectionStore e m -> ClientConnectionStore e m) -> m ()
}
initDefaultStore :: (MonadIO m, MonadIO m2) => m2 (Store event m)
publishEventWith :: (MonadIO m, Eq channel) => Store (Event channel cont) m -> Event channel cont -> m ()
data ClientConnectionStore e (m :: * -> *)
empty :: Collection a coll => coll
toList :: ClientConnectionStore e m -> [(UUID, ClientConnection e m)]
connectionSessionIds :: ClientConnection e m -> [SessionID]
type SessionID = Text
streamApp :: Monad m => App e m -> Input api -> Stream api e m

Documentation

connect :: MonadIO m => m (Input WS) Source #

disconnect :: Scope WS e m -> Input WS -> m () Source #

connectionThread :: MonadUnliftIO m => App e m -> Scope WS e m -> m () Source #

runStreamWS :: Monad m => Scope WS e m -> Stream WS e m -> m () Source #

runStreamHTTP :: Monad m => Scope HTTP e m -> Stream HTTP e m -> m GQLResponse Source #

data Scope (api :: API) event (m :: * -> *) where Source #

Constructors

ScopeHTTP
Fields :: { httpCallback :: event -> m () } -> Scope HTTP event m
ScopeWS
Fields :: { listener :: m ByteString , callback :: ByteString -> m () , update :: (ClientConnectionStore event m -> ClientConnectionStore event m) -> m () } -> Scope WS event m

data Input (api :: API) where Source #

Constructors

Init :: ID -> Input WS
Request :: GQLRequest -> Input HTTP

type WS = WS Source #

type HTTP = HTTP Source #

acceptApolloRequest :: MonadIO m => PendingConnection -> m Connection Source #

publish :: (Monad m, Eq channel) => Event channel content -> ClientConnectionStore (Event channel content) m -> m () Source #

data Store e m Source #

PubSubStore interface shared GraphQL state between websocket and http server, you can define your own store if you provide write and read methods to work properly Morpheus needs all entries of ClientConnectionStore (+ client Callbacks) that why it is recomended that you use many local ClientStores on evenry server node rathen then single centralized Store.

Constructors

Store
Fields readStore :: m (ClientConnectionStore e m) writeStore :: (ClientConnectionStore e m -> ClientConnectionStore e m) -> m ()

initDefaultStore :: (MonadIO m, MonadIO m2) => m2 (Store event m) Source #

initializes empty GraphQL state

publishEventWith :: (MonadIO m, Eq channel) => Store (Event channel cont) m -> Event channel cont -> m () Source #

data ClientConnectionStore e (m :: * -> *) Source #

Instances

Show (ClientConnectionStore e m) Source #
Instance details Defined in Data.Morpheus.Types.Internal.Subscription.ClientConnectionStore Methods showsPrec :: Int -> ClientConnectionStore e m -> ShowS # show :: ClientConnectionStore e m -> String # showList :: [ClientConnectionStore e m] -> ShowS #

empty :: Collection a coll => coll #

toList :: ClientConnectionStore e m -> [(UUID, ClientConnection e m)] Source #

connectionSessionIds :: ClientConnection e m -> [SessionID] Source #

type SessionID = Text Source #

streamApp :: Monad m => App e m -> Input api -> Stream api e m Source #