diff options
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.h | 8 |
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; }; |