Function getWriter

repos/effect/packages/effect/src/unstable/socket/Socket.ts:877–884

(stream: InputTransformStream)

      let open = ws.readyState === 1
      let paused = pausable && "isPaused" in ws && ws.isPaused === true
      let buffer: Array<Uint8Array | string> = []
      let bufferSize = 0
      let error: SocketError | undefined
      let waiter: ReadResume | undefined
      let openWaiter:
        | {
          readonly resume: (effect: Effect.Effect<void, SocketError>) => void
          readonly cleanup: () => void
        }
        | undefined