effect-io-ai

Package: effect
Module: Stream

Stream.toChannel

Creates a channel from a stream.

Example (Converting a stream to a channel)

import { Channel, Console, Effect, Stream } from "effect"

const program = Effect.gen(function*() {
  const stream = Stream.make(1, 2, 3)
  const channel = Stream.toChannel(stream)
  const values = yield* Channel.runCollect(channel)
  yield* Console.log(values.flat())
})

Effect.runPromise(program)
// Output: [ 1, 2, 3 ]

Signature

declare const toChannel: <A, E, R>(stream: Stream<A, E, R>) => Channel.Channel<Arr.NonEmptyReadonlyArray<A>, E, void, unknown, unknown, unknown, R>

Source

Since v2.0.0