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

Function flattenTake

packages/effect/src/Channel.ts:3117–3130  ·  view source on GitHub ↗
(
  self: Channel<Take.Take<OutElem, OutErr, OutDone>, OutErr2, OutDone2, InElem, InErr, InDone, Env>
)

Source from the content-addressed store, hash-verified

3115 * @since 4.0.0
3116 */
3117export const flattenTake = <
3118 OutElem,
3119 OutErr,
3120 OutDone,
3121 OutErr2,
3122 OutDone2,
3123 InElem,
3124 InErr,
3125 InDone,
3126 Env
3127>(
3128 self: Channel<Take.Take<OutElem, OutErr, OutDone>, OutErr2, OutDone2, InElem, InErr, InDone, Env>
3129): Channel<Arr.NonEmptyReadonlyArray<OutElem>, OutErr | OutErr2, OutDone, InElem, InErr, InDone, Env> =>
3130 mapEffectSequential(self, Take.toPull) as any
3131
3132/**
3133 * Creates a new channel that consumes all output from the source channel

Callers

nothing calls this directly

Calls 1

mapEffectSequentialFunction · 0.85

Tested by

no test coverage detected