MCPcopy Index your code
hub / github.com/Effect-TS/effect / drain

Function drain

packages/effect/src/internal/stream.ts:2233–2234  ·  view source on GitHub ↗
(self: Stream.Stream<A, E, R>)

Source from the content-addressed store, hash-verified

2231
2232/** @internal */
2233export const drain = <A, E, R>(self: Stream.Stream<A, E, R>): Stream.Stream<never, E, R> =>
2234 new StreamImpl(channel.drain(toChannel(self)))
2235
2236/** @internal */
2237export const drainFork = dual<

Callers 4

executeFunction · 0.70
stream.tsFile · 0.70
MixedSchedulerClass · 0.50
makeBatchedFunction · 0.50

Calls 1

toChannelFunction · 0.70

Tested by

no test coverage detected