Function writeEffect

packages/platform-node-shared/src/internal/stream.ts:229–252

(
  writable: Writable | NodeJS.WritableStream,
  encoding?: BufferEncoding
)

/** @internal */
export const writeEffect = <A>(
  writable: Writable | NodeJS.WritableStream,
  encoding?: BufferEncoding
) =>
(chunk: Chunk.Chunk<A>) =>
  chunk.length === 0 ?
    Effect.void :
    Effect.async<void>((resume) => {
      const iterator = chunk[Symbol.iterator]()
      let next = iterator.next()
      function loop() {
        const item = next
        next = iterator.next()
        const success = writable.write(item.value, encoding as any)
        if (next.done) {
          resume(Effect.void)
        } else if (success) {
          loop()
        } else {
          writable.once("drain", loop)
        }
      }
      loop()
    })

const unsafeReadableRead = <A, E>(
  readable: Readable | NodeJS.ReadableStream,