Function fromWritableStream

packages/effect/src/Sink.ts:278–288

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

 * @since 4.0.0
 */
export const fromWritableStream = <A, E>(options: {
  readonly evaluate: LazyArg<WritableStream<A>>
  readonly onError: (error: unknown) => E
  readonly closeOnDone?: boolean | undefined
}): Sink<void, A, never, E> =>
  fromChannel(
    Channel.mapDone(
      Channel.fromWritableStream<never, E, A>(options),
      (_) => [_]
    )
  )

/**
 * Creates a `Sink` from a low-level transform function.