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

Function forever

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

Source from the content-addressed store, hash-verified

2969
2970/** @internal */
2971export const forever = <A, E, R>(self: Stream.Stream<A, E, R>): Stream.Stream<A, E, R> =>
2972 new StreamImpl(channel.repeated(toChannel(self)))
2973
2974/** @internal */
2975export const fromAsyncIterable = <A, E>(

Callers 2

fromReadableStreamByobFunction · 0.70
stream.tsFile · 0.70

Calls 1

toChannelFunction · 0.70

Tested by

no test coverage detected