Interruptions and `Stream.toReadableStream`
Is there a way to interrupt effects running inside a stream that was passed to
I figured maybe calling
My use case is that I have an existing app that relies on standard web streaming APIs, and I'd like to incrementally introduce Effect into the codebase. I receive some ReadableStream of values, and I need to produce a ReadableStream that applies a (cancellable) async operation on each element. There's also limits I'm trying to place on concurrency and buffer capacity but that's not directly relevant to my question.
Here is an attempt I made at creating this interface with Effect's streams. Although the stream correctly stops creating new jobs, "Finished job for input 1" prints even after the reader has been cancelled indicating that the AbortSignal provided by
Playground: https://effect.website/play#KABQchk5GyAdGAQhQVwOw
Stream.toReadableStreamI figured maybe calling
reader.cancel()My use case is that I have an existing app that relies on standard web streaming APIs, and I'd like to incrementally introduce Effect into the codebase. I receive some ReadableStream of values, and I need to produce a ReadableStream that applies a (cancellable) async operation on each element. There's also limits I'm trying to place on concurrency and buffer capacity but that's not directly relevant to my question.
Here is an attempt I made at creating this interface with Effect's streams. Although the stream correctly stops creating new jobs, "Finished job for input 1" prints even after the reader has been cancelled indicating that the AbortSignal provided by
Effect.promisePlayground: https://effect.website/play#KABQchk5GyAdGAQhQVwOw
Similar Threads
Was this page helpful?
