Correctness of Broadcasting Stream without maxLag

Stream.fromSchedule(Schedule.spaced('1 second'))
    .pipe((stream) => Effect.gen(function* () {
            const pubsub = yield* Effect.acquireRelease(PubSub.unbounded<Take.Take<number>>(), (pubsub) => PubSub.shutdown(pubsub));
            yield* Effect.fork(Stream.runIntoPubSub(stream, pubsub));
            return Stream.flattenTake(Stream.fromPubSub(pubsub));
        }) )