MCPcopy
hub / github.com/Effect-TS/effect / inner

Function inner

packages/effect/test/Channel/reading.test.ts:108–118  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

106 Channel.fromEffect(Ref.make<ReadonlyArray<number>>([])),
107 Channel.flatMap((ref) => {
108 const inner = (): Channel.Channel<number, number, never, unknown, void, unknown> =>
109 Channel.readWith({
110 onInput: (input: number) =>
111 pipe(
112 Channel.fromEffect(Ref.update(ref, (array) => [...array, input])),
113 Channel.zipRight(Channel.write(input)),
114 Channel.flatMap(inner)
115 ),
116 onFailure: () => Channel.void,
117 onDone: () => Channel.void
118 })
119 return pipe(
120 inner(),
121 Channel.zipRight(Channel.fromEffect(Ref.get(ref)))

Callers 1

reading.test.tsFile · 0.85

Calls 4

fromEffectMethod · 0.80
updateMethod · 0.65
writeMethod · 0.65
pipeFunction · 0.50

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…