const getStream = E.gen(function*() {
const stream = yield* createStream;
const streamB = yield* Stream.share(stream, {
capacity: "unbounded",
});
const streamC = yield* Stream.share(streamB, {
capacity: "unbounded",
});
yield* E.forkDaemon(streamC.pipe(processStream))
return streamB
});
const getStream = E.gen(function*() {
const stream = yield* createStream;
const streamB = yield* Stream.share(stream, {
capacity: "unbounded",
});
const streamC = yield* Stream.share(streamB, {
capacity: "unbounded",
});
yield* E.forkDaemon(streamC.pipe(processStream))
return streamB
});