WebSocketMessageHandler

type WebSocketMessageHandler<D extends InjectMap, T extends WebSocketDescriptor> = (socket: FlareWebSocketContext<WebSocketOutgoing<T>>, scope: WebSocketMessageHandlerScope<D, T>) => void | Promise<void>

message handler: runs per inbound message; the payload is on scope.input.message. Async => backpressure.

Learn: Inline handlers