Stream.unwrap Simplifies Event Processing Pipeline in TypeScript

const events = yield* readByLAbel(label, query).pipe(
          Effect.andThen(
            flow(
              toStream,
              Stream.flatMap(Stream.fromIterable),
              Stream.take(limit),
              Stream.mapEffect(decodeEvents),
              Stream.map((x) => ({ ...x.value, ...x })),
              Stream.runCollect
            )
          )
        );
        return yield* Effect.succeed({ events: Chunk.toArray(events) });

const events = yield* readByLAbel(label, query).pipe(
          Effect.map(toStream),
          Stream.unwrap,
          Stream.flatMap(Stream.fromIterable),
          Stream.take(limit),
          Stream.mapEffect(decodeEvents),
          Stream.map((x) => ({ ...x.value, ...x })),
          Stream.runCollect
        );
        return yield* Effect.succeed({ events: Chunk.toArray(events) });