-
Notifications
You must be signed in to change notification settings - Fork 591
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
datastore: runQuery as a stream. fixes #289 #291
datastore: runQuery as a stream. fixes #289 #291
Conversation
@@ -278,8 +279,7 @@ describe('Request', function() { | |||
entity_result: mockRespGet.found, | |||
end_cursor: new ByteBuffer().writeIString('cursor').flip() | |||
} | |||
}, | |||
withoutResults: mockRespGet |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
stream.once('reading', runQuery); | ||
return stream; | ||
} else { | ||
callback = callback || util.noop; |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This looks good too! :) 👍 |
…stream datastore: runQuery as a stream. fixes #289
Oops I merged this before you could fix the callback thing. Not a big deal, just throw it in your next PR. |
@ryanseys what is the callback thing? can we make sure we have an issue to track it if it hasn't been fixed yet? |
@@ -248,6 +248,21 @@ describe('datastore', function() { | |||
}); | |||
}); | |||
|
|||
it('should run a query as a stream', function(done) { | |||
var q = ds.createQuery('Character').hasAncestor(ancestor) | |||
.limit(5); |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
The library is regenerated with gapic-generator-typescript v1.3.1. Committer: @alexander-fenster PiperOrigin-RevId: 372468161 Source-Link: googleapis/googleapis@75880c3 Source-Link: googleapis/googleapis-gen@77b1804
* Added/exposed CLI functionality for dataproc quickstart Co-authored-by: Benjamin E. Coe <bencoe@google.com>
🤖 I have created a release \*beep\* \*boop\* --- ### [2.2.4](https://www.github.com/googleapis/nodejs-datalabeling/compare/v2.2.3...v2.2.4) (2021-06-30) ### Bug Fixes * **deps:** google-gax v2.17.0 with mTLS ([#291](https://www.github.com/googleapis/nodejs-datalabeling/issues/291)) ([ba455a8](https://www.github.com/googleapis/nodejs-datalabeling/commit/ba455a8d574f9bb87c9f7531ba56e199ad0dc8be)) --- This PR was generated with [Release Please](https://github.com/googleapis/release-please). See [documentation](https://github.com/googleapis/release-please#release-please).
* chore: migrate to owl bot * chore: copy files from googleapis-gen fb91803ccef5d7c695139b22788b309e2197856b * chore: run the post processor * 🦉 Updates from OwlBot Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
fix: use google-gax v3.3.0 Source-Link: googleapis/synthtool@c73d112 Post-Processor: gcr.io/cloud-devrel-public-resources/owlbot-nodejs:latest@sha256:b15a6f06cc06dcffa11e1bebdf1a74b6775a134aac24a0f86f51ddf728eb373e
Co-authored-by: release-please[bot] <55107282+release-please[bot]@users.noreply.github.com>
* updated CHANGELOG.md [ci skip] * updated package.json [ci skip] * updated samples/package.json Co-authored-by: release-please[bot] <55107282+release-please[bot]@users.noreply.github.com>
🤖 I have created a release \*beep\* \*boop\* --- ### [2.4.2](https://www.github.com/googleapis/nodejs-datacatalog/compare/v2.4.1...v2.4.2) (2021-08-17) ### Bug Fixes * **deps:** google-gax v2.24.1 ([#291](https://www.github.com/googleapis/nodejs-datacatalog/issues/291)) ([b9f80cd](https://www.github.com/googleapis/nodejs-datacatalog/commit/b9f80cd961a516c967d20c66b3752cadd9ed9546)) --- This PR was generated with [Release Please](https://github.com/googleapis/release-please). See [documentation](https://github.com/googleapis/release-please#release-please).
No description provided.