stream

stream copied to clipboard

RuntimeException: BUG: Sink.fromPush

2

I've been playing with `Ref`, `Stream` and `Sink` and have triggered the message at https://github.com/Effect-TS/stream/blob/8dda24823dc77b1d6763c4988f7c37246d566dfe/src/internal/sink.ts#L1498 Reporting as requested :) ```ts import { Chunk, Context, Effect, HashMap, Layer, Option, Ref, Sink,...

GraemeF

# Summary The user is reporting a bug in the @effect/stream library where merging streams is causing a leaking handle. They are unsure if they are misusing the library or...

effect-bot

add serviceFunctions, serviceConstants and serviceMembers (fixes #175)

1

sledorze

implement the moral equivalent of Effect serviceFunctions / serviceConstants / serviceMembers

1

This is linked to https://github.com/Effect-TS/io/issues/634

sledorze

`broadcastDynamic` broken

4

The following doesn't return: ```ts import * as Effect from "@effect/io/Effect" import * as Stream from "@effect/stream/Stream" import { pipe } from "@fp-ts/core/Function" pipe( Stream.fail("fail"), Stream.broadcastDynamic(1), Effect.flatMap((_) => Effect.zipPar(Stream.runDrain(_), Stream.runDrain(_))),...

mikearnaldi