Interface WsSubscription

web/crux/src/websockets/common.ts:51–57

}

export interface WsSubscription {
  getCompleter(clientToken: string): Observable<unknown>
  getParameter(name: string): string
  onMessage(client: WsClient, message: WsMessage): Observable<any>
  sendToAll(message: WsMessage): void
  sendToAllExcept(except: WsClient, message: WsMessage): void
}

export type WsSendClientMessage = (message: WsMessage) => void
export type WsClient = WebSocket & {