effect-io-ai

Package: effect
Module: Stream

Stream.fromChannel

Creates a stream from a array-emitting Channel.

Example (Creating a stream from an array-emitting channel)

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

const program = Effect.gen(function*() {
  const channel = Channel.succeed([1, 2, 3] as const)
  const stream = Stream.fromChannel(channel)
  const result = yield* Stream.runCollect(stream)
  yield* Console.log(result)
})

// Output: [ 1, 2, 3 ]

Signature

declare const fromChannel: <Arr extends Arr.NonEmptyReadonlyArray<any>, E, R>(channel: Channel.Channel<Arr, E, void, unknown, unknown, unknown, R>) => Stream<Arr extends Arr.NonEmptyReadonlyArray<infer A> ? A : never, E, R>

Source

Since v2.0.0