Running Two Async Iterators Concurrently in Effect Typescript

    const program = Effect.gen(function* () {
      yield* Effect.sleep(0);

      const bybit = yield* Effect.acquireRelease(
        Effect.tryPromise(() => bybitClient.events.subscribe({})),
        release("Bybit released")
      );

      const saxo = yield* Effect.acquireRelease(
        Effect.tryPromise(() => saxoClient.events.subscribe({})),
        release("Saxo released")
      );

      yield* Stream.merge(toStream(bybit), toStream(saxo)).pipe(
        Stream.runForEach((e) => Effect.sync(() => toastEvent(e)))
      );

      function release(message: string) {
        return (iterator: AsyncIterator<TradeEvent>) =>
          Effect.all([
            Console.log(message),
            Effect.sync(() => iterator.return?.()),
          ]);
      }

      function toStream(iterable: AsyncIterable<TradeEvent>) {
        return Stream.fromAsyncIterable(iterable, (e) => new Error(String(e)));
      }
    }).pipe(Effect.scoped);