diff options
| author | Rishab Joshi <rishab.joshi@mongodb.com> | 2021-05-11 14:12:34 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2021-05-20 00:55:21 +0000 |
| commit | e53e42046e8e25f4cf9b6ffa68c71c2add8ae793 (patch) | |
| tree | 14ed8d4743ef7146ee6da8f255f6fd3b1657a720 /src/mongo/db/pipeline/plan_executor_pipeline.h | |
| parent | 189c806cc7ec182173ed82c85503f30472a25b5b (diff) | |
| download | mongo-e53e42046e8e25f4cf9b6ffa68c71c2add8ae793.tar.gz | |
SERVER-56696: Introduce a new change stream stage to handle the topology
change event.
Diffstat (limited to 'src/mongo/db/pipeline/plan_executor_pipeline.h')
| -rw-r--r-- | src/mongo/db/pipeline/plan_executor_pipeline.h | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/src/mongo/db/pipeline/plan_executor_pipeline.h b/src/mongo/db/pipeline/plan_executor_pipeline.h index 7fbb0d677b4..ed77e3cc8c1 100644 --- a/src/mongo/db/pipeline/plan_executor_pipeline.h +++ b/src/mongo/db/pipeline/plan_executor_pipeline.h @@ -157,6 +157,12 @@ private: boost::optional<Document> _getNext(); /** + * Obtains the next result from the pipeline, gracefully handling any known exceptions which may + * be thrown. + */ + boost::optional<Document> _tryGetNext(); + + /** * For a change stream or resumable oplog scan, updates the scan state based on the latest * document returned by the underlying pipeline. */ |