MCPcopy Create free account
hub / github.com/Effect-TS/effect / serveWebSocket

Function serveWebSocket

packages/platform/deno/test/DenoHttpServer.test.ts:689–701  ·  view source on GitHub ↗
(
  run: (socket: Socket.Socket) => Effect.Effect<void, Socket.SocketError, Scope.Scope>
)

Source from the content-addressed store, hash-verified

687})
688
689const serveWebSocket = (
690 run: (socket: Socket.Socket) => Effect.Effect<void, Socket.SocketError, Scope.Scope>
691) =>
692 HttpRouter.add(
693 "GET",
694 "/",
695 Effect.gen(function*() {
696 const request = yield* HttpServerRequest.HttpServerRequest
697 const socket = yield* request.upgrade
698 yield* run(socket)
699 return HttpServerResponse.empty()
700 })
701 ).pipe(HttpRouter.serve, Layer.build)
702
703const openWebSocket = (url: string) =>
704 Effect.acquireRelease(

Callers 1

Calls 3

pipeMethod · 0.65
addMethod · 0.65
runFunction · 0.50

Tested by

no test coverage detected