Function write

packages/effect/src/unstable/socket/Socket.ts:738–753

(chunk: Uint8Array | string | CloseEvent)

      )

    const write = (chunk: Uint8Array | string | CloseEvent) =>
      latch.whenOpen(
        Effect.suspend(() => {
          try {
            const ws = currentWS!
            if (isCloseEvent(chunk)) {
              ws.close(chunk.code, chunk.reason)
            } else {
              ws.send(chunk as string | Uint8Array<ArrayBuffer>)
            }
            return Effect.void
          } catch (cause) {
            return Effect.fail(new SocketError({ reason: new SocketWriteError({ cause }) }))
          }
        })
      )
    const writer = Effect.succeed(write)

    return Effect.succeed(make({