MCPcopy Create free account
hub / github.com/effect-app/libs / fromEffectDrain

Function fromEffectDrain

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

Source from the content-addressed store, hash-verified

466 *
467 * const stream = Stream.fromEffectSchedule(Effect.succeed("ping"), Schedule.recurs(2))
468 * await Effect.runPromise(Stream.runCollect(stream)) // => ["ping", "ping", "ping"]
469 * ```
470 *
471 * @category constructors
472 * @since 4.0.0

Callers 1

Stream.tsFile · 0.70

Calls 3

doneMethod · 0.80
fromPullFunction · 0.70
succeedMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…