summaryrefslogtreecommitdiff
path: root/src/mongo/db/pipeline/document_source_change_stream_close_cursor.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/pipeline/document_source_change_stream_close_cursor.h')
-rw-r--r--src/mongo/db/pipeline/document_source_change_stream_close_cursor.h8
1 files changed, 5 insertions, 3 deletions
diff --git a/src/mongo/db/pipeline/document_source_change_stream_close_cursor.h b/src/mongo/db/pipeline/document_source_change_stream_close_cursor.h
index ab28dee5e8d..6fc042b9bb4 100644
--- a/src/mongo/db/pipeline/document_source_change_stream_close_cursor.h
+++ b/src/mongo/db/pipeline/document_source_change_stream_close_cursor.h
@@ -43,11 +43,11 @@ namespace mongo {
*/
class DocumentSourceCloseCursor final : public DocumentSource {
public:
- GetNextResult getNext() final;
+ static constexpr StringData kStageName = "$changeStream"_sd;
const char* getSourceName() const final {
// This is used in error reporting.
- return "$changeStream";
+ return DocumentSourceCloseCursor::kStageName.rawData();
}
StageConstraints constraints(Pipeline::SplitState pipeState) const final {
@@ -88,7 +88,9 @@ private:
* Use the create static method to create a DocumentSourceCloseCursor.
*/
DocumentSourceCloseCursor(const boost::intrusive_ptr<ExpressionContext>& expCtx)
- : DocumentSource(expCtx) {}
+ : DocumentSource(kStageName, expCtx) {}
+
+ GetNextResult doGetNext() final;
bool _shouldCloseCursor = false;
};