mars.websocket

Vibe gestisce la ricezione di dati da websocket con una wait bloccante, cosa ottima per un protocollo req/rep, ma complicata se si vuol gestire in contemporanea anche un protocollo push lato server, o task paralleli.

Questo modulo si occupa di isolare il websocket, inviando i dati ricevuti ad un task, e facendo da proxy per i send.

Members

Enums

Flow enum Flow: Undocumented in source.
ReceiveMode enum ReceiveMode: Undocumented in source.

Functions

handleWebSocketConnectionClientToService void handleWebSocketConnectionClientToService(WebSocket webSocket): * Entry point of the task that is handling the websocket connection with the client that has just joined us.
handleWebSocketConnectionServiceToClient void handleWebSocketConnectionServiceToClient(WebSocket webSocket): Entry point of the task that is handling the connection that allow the service to push messages to the web client.

Structs

HandlerBinaryData struct HandlerBinaryData: Undocumented in source.
HandlerData struct HandlerData: Undocumented in source.
ResilientWebSocket struct ResilientWebSocket: WebSocket resilient to network disconnections.
SocketBinaryData struct SocketBinaryData: Undocumented in source.
SocketData struct SocketData: Undocumented in source.

mars.websocket

Members

Enums

Functions

Structs

Meta

Source