yield* pubsub.subscribe().pipe(
Effect.map(queue => Stream.fromQueue(queue)),
Effect.flatMap(Stream.runForEach(onEvent)),
Effect.fork
)
yield* pubsub.subscribe().pipe(
Effect.map(queue => Stream.fromQueue(queue)),
Effect.flatMap(Stream.runForEach(onEvent)),
Effect.fork
)