Instead of this: ```ts const batches = await firstValueFrom(pipe(this.raw, toArray())); ``` you can do this: ```ts const batches = await pipe(this.raw, toArray()).first; ```