(
transform: (
upstream: Pull.Pull<NonEmptyReadonlyArray<In>, never, void>,
scope: Scope.Scope
) => Effect.Effect<End<A, L>, E, R>
)
| 252 | |
| 253 | /** |
| 254 | * Creates a sink that writes its input to a Web `WritableStream`. |
| 255 | * |
| 256 | * **Example** (Collecting values in a Web stream) |
| 257 | * |
| 258 | * ```ts import.meta.vitest |
| 259 | * import { Effect, Sink, Stream } from "effect" |
| 260 | * |
| 261 | * const written: Array<number> = [] |
| 262 | * const sink = Sink.fromWritableStream({ |
| 263 | * evaluate: () => new WritableStream<number>({ |
| 264 | * write(value) { |
| 265 | * written.push(value) |
| 266 | * } |
no outgoing calls
no test coverage detected
searching dependent graphs…