MCPcopy Create free account
hub / github.com/Effect-TS/effect / fromEffectDrain

Function fromEffectDrain

packages/effect/src/Stream.ts:435–436  ·  view source on GitHub ↗
(effect: Effect.Effect<A, E, R>)

Source from the content-addressed store, hash-verified

433 * @since 4.0.0
434 */
435export const fromEffectDrain = <A, E, R>(effect: Effect.Effect<A, E, R>): Stream<never, E, R> =>
436 fromPull(Effect.succeed(Effect.flatMap(effect, () => Cause.done())))
437
438/**
439 * Creates a stream from an effect producing a value of type `A` which repeats forever.

Callers 1

Stream.tsFile · 0.70

Calls 3

fromPullFunction · 0.70
succeedMethod · 0.45
doneMethod · 0.45

Tested by

no test coverage detected