How to Merge Two Queues into a Stream in TypeScript

  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)),
        );

        ...
     }))