Repository navigation
BigTable asynchronous row handling #1715
Description
Activity
What about something like this?
$ npm install --save through2
var through = require('through2'); table.createReadStream() .on('error', console.error) .pipe(through.obj((row, _, next) => { doSomeExpensiveWork() .then(() => next(null), next); }) .on('finish', function() { // all done! });
Yep, that's what I would say. It will not pull more data from the stream until you're done processing the last result.
In case users of other APIs see this, this will work for any object stream from our APIs.
- added a commit that references this issue
on Feb 25, 2026 - added a commit that references this issue
on Mar 17, 2026 - added 4 commits that reference this issue
on Mar 23, 2026 - added 2 commits that reference this issue
on Mar 27, 2026
Is there a way to asynchronously handle rows with a BigTable range query? What I'm trying to do is something like this: