Function fromWritableStream

packages/effect/src/Channel.ts:1745–1753

(options: {
  readonly evaluate: LazyArg<WritableStream<A>>
  readonly onError: (error: unknown) => E
  readonly closeOnDone?: boolean | undefined
})

 * @since 4.0.0
 */
export const fromWritableStream = <IE, E, A>(options: {
  readonly evaluate: LazyArg<WritableStream<A>>
  readonly onError: (error: unknown) => E
  readonly closeOnDone?: boolean | undefined
}): Channel<never, IE | E, void, Arr.NonEmptyReadonlyArray<A>, IE> =>
  fromTransform((pull: Pull.Pull<Arr.NonEmptyReadonlyArray<A>, IE, unknown>) => {
    const writable = options.evaluate()
    return Effect.succeed(pullIntoWritableStream({ ...options, writable, pull }))
  })

/**
 * Creates a channel backed by a Web `TransformStream`, writing upstream values