const startNixTimerSubscriber = yield* pubsub.subscribeTo("StartNixTimer");
const stopNixTimerSubscriber = yield* pubsub.subscribeTo("StopNixTimer");
const stream = Stream.merge(
Stream.fromQueue(startNixTimerSubscriber),
Stream.fromQueue(stopNixTimerSubscriber),
);
yield* Effect.forkScoped(
Effect.forever(
Effect.gen(function* () {
const message = yield* Stream.take(stream, 1).pipe(
Stream.runCollect,
Effect.andThen(Chunk.unsafeGet(1)),
);
...
}))
const startNixTimerSubscriber = yield* pubsub.subscribeTo("StartNixTimer");
const stopNixTimerSubscriber = yield* pubsub.subscribeTo("StopNixTimer");
const stream = Stream.merge(
Stream.fromQueue(startNixTimerSubscriber),
Stream.fromQueue(stopNixTimerSubscriber),
);
yield* Effect.forkScoped(
Effect.forever(
Effect.gen(function* () {
const message = yield* Stream.take(stream, 1).pipe(
Stream.runCollect,
Effect.andThen(Chunk.unsafeGet(1)),
);
...
}))