Saltar al contenido
Meeko
Escribe para buscar en las guías y en la referencia de la API. Ábrela desde cualquier página con / o Ctrl K; muévete con las flechas y entra con Intro.
Empezar

Contenidos

En esta página

NodeAcceptedSocket

interfaz

Conexión que devuelve la librería WebSocket del host tras el upgrade; la librería se encarga del framing y de la respuesta HTTP 101.

ts
import type { NodeAcceptedSocket } from "@meekojs/meeko/node";

Código fuente src/server/runtime/node-upgrade.ts:26

Declaración #

ts
interface NodeAcceptedSocket {
	peer: SocketPeer
	onMessage(listener: (message: string | Uint8Array) => void): void
	onClose(listener: () => void): void
}

Ejemplo #

ts
import type WebSocket from "ws";
import type { NodeAcceptedSocket } from "@meekojs/meeko/node";

const accepted = (socket: WebSocket): NodeAcceptedSocket => ({
  peer: { send: (message) => socket.send(message), close: (code, reason) => socket.close(code, reason) },
  onMessage: (listener) => socket.on("message", (data, binary) => listener(binary ? new Uint8Array(data as Buffer) : data.toString())),
  onClose: (listener) => socket.on("close", listener),
});

Miembros #

peer #

propiedad

Peer que recibe los envíos del hub.

onMessage #

método

onMessage(listener: (message: string | Uint8Array) => void): void

Registra el listener de los mensajes entrantes.

onClose #

método

onClose(listener: () => void): void

Registra el listener del cierre.

Véase también #

¿Te sirvió esta página?

Añadir un comentario

Se envía al elegir «Sí» o «No». Solo se guardan la página, tu respuesta y el comentario: ni cookies ni datos tuyos.

0 de 2000 caracteres

Editar en GitHub: packages/meeko/src/server/runtime/node-upgrade.ts