Yesod.WebSockets

Core API

type WebSocketsT = ReaderT Connection

A transformer for a WebSockets handler.

Since 0.1.0

webSockets :: (MonadBaseControl IO m, MonadHandler m) => WebSocketsT m () -> m ()

Attempt to run a WebSockets handler. This function first checks if the client initiated a WebSockets connection and, if so, runs the provided application, short-circuiting the rest of your handler. If the client did not request a WebSockets connection, the rest of your handler will be called instead.

Since 0.1.0

webSocketsWith

Arguments

:: (MonadBaseControl IO m, MonadHandler m)

=> (RequestHead -> m (Maybe AcceptRequest))

A Nothing indicates that the websocket upgrade request should not happen and instead the rest of the handler will be called instead. This allows you to use getRequestSubprotocols and only accept the request if a compatible subprotocol is given. Also, the action runs before upgrading the request to websockets, so you can also use short-circuiting handler actions such as invalidArgs.

-> WebSocketsT m ()

-> m ()

Varient of webSockets which allows you to specify the AcceptRequest setttings when upgrading to a websocket connection.

Since 0.2.4

receiveData :: (MonadIO m, WebSocketsData a) => WebSocketsT m a

Receive a piece of data from the client.

Since 0.1.0

receiveDataE :: (MonadIO m, WebSocketsData a) => WebSocketsT m (Either SomeException a)

Receive a piece of data from the client. Capture SomeException as the result or operation Since 0.2.2

receiveDataMessageE :: MonadIO m => WebSocketsT m (Either SomeException DataMessage)

Receive an application message. Capture SomeException as the result or operation Since 0.2.3

sendPing :: (MonadIO m, WebSocketsData a) => a -> WebSocketsT m ()

Send a ping message to the client.

Since 0.2.2

sendPingE :: (MonadIO m, WebSocketsData a) => a -> WebSocketsT m (Either SomeException ())

Send a ping message to the client. Capture SomeException as the result of operation Since 0.2.2

sendClose :: (MonadIO m, WebSocketsData a) => a -> WebSocketsT m ()

Send a close request to the client.

Since 0.2.2

sendCloseE :: (MonadIO m, WebSocketsData a) => a -> WebSocketsT m (Either SomeException ())

Send a close request to the client. Capture SomeException as the result of operation Since 0.2.2

sendTextData :: (MonadIO m, WebSocketsData a) => a -> WebSocketsT m ()

Send a textual message to the client.

Since 0.1.0

sendTextDataE :: (MonadIO m, WebSocketsData a) => a -> WebSocketsT m (Either SomeException ())

Send a textual message to the client. Capture SomeException as the result or operation and can be used like `either handle_exception return =<< sendTextDataE (Welcome :: Text)` Since 0.2.2

sendBinaryData :: (MonadIO m, WebSocketsData a) => a -> WebSocketsT m ()

Send a binary message to the client.

Since 0.1.0

sendBinaryDataE :: (MonadIO m, WebSocketsData a) => a -> WebSocketsT m (Either SomeException ())

Send a binary message to the client. Capture SomeException as the result of operation Since 0.2.2

sendDataMessageE :: MonadIO m => DataMessage -> WebSocketsT m (Either SomeException ())

Send a DataMessage to the client. Capture SomeException as the result of operation Since 0.2.3

Conduit API

sourceWS :: (MonadIO m, WebSocketsData a) => Producer (WebSocketsT m) a

A Source of WebSockets data from the user.

Since 0.1.0

sinkWSText :: (MonadIO m, WebSocketsData a) => Consumer a (WebSocketsT m) ()

A Sink for sending textual data to the user.

Since 0.1.0

sinkWSBinary :: (MonadIO m, WebSocketsData a) => Consumer a (WebSocketsT m) ()

A Sink for sending binary data to the user.

Since 0.1.0

Async helpers

race :: MonadBaseControl IO m => m a -> m b -> m (Either a b)

Generalized version of race.

Since 0.1.0

race_ :: MonadBaseControl IO m => m a -> m b -> m ()

Generalized version of race_.

Since 0.1.0

concurrently :: MonadBaseControl IO m => m a -> m b -> m (a, b)

Generalized version of concurrently. Note that if your underlying monad has some kind of mutable state, the state from the second action will overwrite the state from the first.

Since 0.1.0

concurrently_ :: MonadBaseControl IO m => m a -> m b -> m ()

Run two actions concurrently (like concurrently), but discard their results and any modified monadic state.

Since 0.1.0