CSHARP-2023: Rename ChangeStreamOutput to ChangeStreamDocument.

rstam · rstam · commit 1005873e9165 · 2017-10-11T16:27:42.000-04:00
diff --git a/src/MongoDB.Driver.Core/ChangeStreamDocument.cs b/src/MongoDB.Driver.Core/ChangeStreamDocument.cs
@@ -21,7 +21,7 @@ namespace MongoDB.Driver
     /// <summary>
     /// An output document from a $changeStream pipeline stage.
     /// </summary>
-    public sealed class ChangeStreamOutput<TDocument>
+    public sealed class ChangeStreamDocument<TDocument>
     {
         // private fields
         private readonly CollectionNamespace _collectionNamespace;
@@ -33,15 +33,15 @@ public sealed class ChangeStreamOutput<TDocument>
 
         // constructors
         /// <summary>
-        /// Initializes a new instance of the <see cref="ChangeStreamOutput{TDocument}" /> class.
+        /// Initializes a new instance of the <see cref="ChangeStreamDocument{TDocument}" /> class.
         /// </summary>
         /// <param name="resumeToken">The resume token.</param>
         /// <param name="operationType">Type of the operation.</param>
         /// <param name="collectionNamespace">Namespace of the collection.</param>
         /// <param name="documentKey">The document key.</param>
         /// <param name="updateDescription">The update description.</param>
         /// <param name="fullDocument">The full document.</param>
-        public ChangeStreamOutput(
+        public ChangeStreamDocument(
             BsonDocument resumeToken,
             ChangeStreamOperationType operationType,
             CollectionNamespace collectionNamespace,
diff --git a/src/MongoDB.Driver.Core/ChangeStreamDocumentSerializer.cs b/src/MongoDB.Driver.Core/ChangeStreamDocumentSerializer.cs
@@ -24,10 +24,10 @@ namespace MongoDB.Driver
 {
 
     /// <summary>
-    /// A serializer for ChangeStreamOutput instances.
+    /// A serializer for ChangeStreamDocument instances.
     /// </summary>
     /// <typeparam name="TDocument">The type of the document.</typeparam>
-    public class ChangeStreamOutputSerializer<TDocument> : SealedClassSerializerBase<ChangeStreamOutput<TDocument>>
+    public class ChangeStreamDocumentSerializer<TDocument> : SealedClassSerializerBase<ChangeStreamDocument<TDocument>>
     {
         #region static
         // private static fields
@@ -40,18 +40,18 @@ public class ChangeStreamOutputSerializer<TDocument> : SealedClassSerializerBase
 
         // constructors
         /// <summary>
-        /// Initializes a new instance of the <see cref="ChangeStreamOutputSerializer{TDocument}"/> class.
+        /// Initializes a new instance of the <see cref="ChangeStreamDocumentSerializer{TDocument}"/> class.
         /// </summary>
         /// <param name="documentSerializer">The document serializer.</param>
-        public ChangeStreamOutputSerializer(
+        public ChangeStreamDocumentSerializer(
             IBsonSerializer<TDocument> documentSerializer)
         {
             _documentSerializer = Ensure.IsNotNull(documentSerializer, nameof(documentSerializer));
         }
 
         // public methods
         /// <inheritdoc />
-        protected override ChangeStreamOutput<TDocument> DeserializeValue(BsonDeserializationContext context, BsonDeserializationArgs args)
+        protected override ChangeStreamDocument<TDocument> DeserializeValue(BsonDeserializationContext context, BsonDeserializationArgs args)
         {
             var reader = context.Reader;
 
@@ -106,7 +106,7 @@ protected override ChangeStreamOutput<TDocument> DeserializeValue(BsonDeserializ
             }
             reader.ReadEndDocument();
 
-            return new ChangeStreamOutput<TDocument>(
+            return new ChangeStreamDocument<TDocument>(
                 resumeToken,
                 operationType.Value,
                 collectionNamespace,
@@ -116,7 +116,7 @@ protected override ChangeStreamOutput<TDocument> DeserializeValue(BsonDeserializ
         }
 
         /// <inheritdoc />
-        protected override void SerializeValue(BsonSerializationContext context, BsonSerializationArgs args, ChangeStreamOutput<TDocument> value)
+        protected override void SerializeValue(BsonSerializationContext context, BsonSerializationArgs args, ChangeStreamDocument<TDocument> value)
         {
             var writer = context.Writer;
             writer.WriteStartDocument();
diff --git a/src/MongoDB.Driver.Core/ChangeStreamFullDocumentOptions.cs b/src/MongoDB.Driver.Core/ChangeStreamFullDocumentOptions.cs
@@ -25,7 +25,9 @@ public enum ChangeStreamFullDocumentOption
         /// </summary>
         Default = 0,
         /// <summary>
-        /// Lookup the full document and return it.
+        /// The change stream for partial updates will include both a delta describing the
+        /// changes to the document as well as a copy of the entire document that was
+        /// changed from some time after the change occurred.
         /// </summary>
         UpdateLookup
     }
diff --git a/src/MongoDB.Driver.Core/ChangeStreamUpdateDescription.cs b/src/MongoDB.Driver.Core/ChangeStreamUpdateDescription.cs
@@ -19,7 +19,7 @@
 namespace MongoDB.Driver
 {
     /// <summary>
-    /// An UpdateDescription in a ChangeStreamOutput instance.
+    /// An UpdateDescription in a ChangeStreamDocument instance.
     /// </summary>
     public sealed class ChangeStreamUpdateDescription
     {
diff --git a/src/MongoDB.Driver.Core/MongoDB.Driver.Core.csproj b/src/MongoDB.Driver.Core/MongoDB.Driver.Core.csproj
@@ -54,8 +54,8 @@
     <Compile Include="ChangeStreamFullDocumentOptions.cs" />
     <Compile Include="ChangeStreamOperationType.cs" />
     <Compile Include="ChangeStreamOperationTypeSerializer.cs" />
-    <Compile Include="ChangeStreamOutput.cs" />
-    <Compile Include="ChangeStreamOutputSerializer.cs" />
+    <Compile Include="ChangeStreamDocument.cs" />
+    <Compile Include="ChangeStreamDocumentSerializer.cs" />
     <Compile Include="ChangeStreamUpdateDescription.cs" />
     <Compile Include="ChangeStreamUpdateDescriptionSerializer.cs" />
     <Compile Include="Collation.cs" />
diff --git a/src/MongoDB.Driver/AggregateFluent.cs b/src/MongoDB.Driver/AggregateFluent.cs
@@ -98,7 +98,7 @@ public override IAggregateFluent<TNewResult> BucketAuto<TValue, TNewResult>(
             return WithPipeline(_pipeline.BucketAuto(groupBy, buckets, output, options));
         }
 
-        public override IAggregateFluent<ChangeStreamOutput<TResult>> ChangeStream(ChangeStreamStageOptions options = null)
+        public override IAggregateFluent<ChangeStreamDocument<TResult>> ChangeStream(ChangeStreamStageOptions options = null)
         {
             return WithPipeline(_pipeline.ChangeStream(options));
         }
diff --git a/src/MongoDB.Driver/AggregateFluentBase.cs b/src/MongoDB.Driver/AggregateFluentBase.cs
@@ -86,7 +86,7 @@ public virtual IAggregateFluent<TNewResult> BucketAuto<TValue, TNewResult>(
         }
 
         /// <inheritdoc />
-        public virtual IAggregateFluent<ChangeStreamOutput<TResult>> ChangeStream(ChangeStreamStageOptions options = null)
+        public virtual IAggregateFluent<ChangeStreamDocument<TResult>> ChangeStream(ChangeStreamStageOptions options = null)
         {
             throw new NotImplementedException(); // implemented by subclasses
         }
diff --git a/src/MongoDB.Driver/IAggregateFluent.cs b/src/MongoDB.Driver/IAggregateFluent.cs
@@ -129,7 +129,7 @@ IAggregateFluent<TNewResult> BucketAuto<TValue, TNewResult>(
         /// </summary>
         /// <param name="options">The options.</param>
         /// <returns>The fluent aggregate interface.</returns>
-        IAggregateFluent<ChangeStreamOutput<TResult>> ChangeStream(ChangeStreamStageOptions options = null);
+        IAggregateFluent<ChangeStreamDocument<TResult>> ChangeStream(ChangeStreamStageOptions options = null);
 
         /// <summary>
         /// Appends a count stage to the pipeline.
diff --git a/src/MongoDB.Driver/IMongoCollection.cs b/src/MongoDB.Driver/IMongoCollection.cs
@@ -481,7 +481,7 @@ public interface IMongoCollection<TDocument>
         /// A change stream.
         /// </returns>
         IAsyncCursor<TResult> Watch<TResult>(
-            PipelineDefinition<ChangeStreamOutput<TDocument>, TResult> pipeline,
+            PipelineDefinition<ChangeStreamDocument<TDocument>, TResult> pipeline,
             ChangeStreamOptions options = null,
             CancellationToken cancellationToken = default(CancellationToken));
 
@@ -496,7 +496,7 @@ IAsyncCursor<TResult> Watch<TResult>(
         /// A change stream.
         /// </returns>
         Task<IAsyncCursor<TResult>> WatchAsync<TResult>(
-            PipelineDefinition<ChangeStreamOutput<TDocument>, TResult> pipeline,
+            PipelineDefinition<ChangeStreamDocument<TDocument>, TResult> pipeline,
             ChangeStreamOptions options = null,
             CancellationToken cancellationToken = default(CancellationToken));
 
diff --git a/src/MongoDB.Driver/IMongoCollectionExtensions.cs b/src/MongoDB.Driver/IMongoCollectionExtensions.cs
@@ -1032,12 +1032,12 @@ public static IFindFluent<TDocument, TDocument> Find<TDocument>(this IMongoColle
         /// <returns>
         /// A change stream.
         /// </returns>
-        public static IAsyncCursor<ChangeStreamOutput<TDocument>> Watch<TDocument>(
+        public static IAsyncCursor<ChangeStreamDocument<TDocument>> Watch<TDocument>(
             this IMongoCollection<TDocument> collection,
             ChangeStreamOptions options = null,
             CancellationToken cancellationToken = default(CancellationToken))
         {
-            var emptyPipeline = new EmptyPipelineDefinition<ChangeStreamOutput<TDocument>>();
+            var emptyPipeline = new EmptyPipelineDefinition<ChangeStreamDocument<TDocument>>();
             return collection.Watch(emptyPipeline, options, cancellationToken);
         }
 
@@ -1051,12 +1051,12 @@ public static IAsyncCursor<ChangeStreamOutput<TDocument>> Watch<TDocument>(
         /// <returns>
         /// A change stream.
         /// </returns>
-        public static Task<IAsyncCursor<ChangeStreamOutput<TDocument>>> WatchAsync<TDocument>(
+        public static Task<IAsyncCursor<ChangeStreamDocument<TDocument>>> WatchAsync<TDocument>(
             this IMongoCollection<TDocument> collection,
             ChangeStreamOptions options = null,
             CancellationToken cancellationToken = default(CancellationToken))
         {
-            var emptyPipeline = new EmptyPipelineDefinition<ChangeStreamOutput<TDocument>>();
+            var emptyPipeline = new EmptyPipelineDefinition<ChangeStreamDocument<TDocument>>();
             return collection.WatchAsync(emptyPipeline, options, cancellationToken);
         }
     }
diff --git a/src/MongoDB.Driver/MongoCollectionBase.cs b/src/MongoDB.Driver/MongoCollectionBase.cs
@@ -496,7 +496,7 @@ public virtual Task InsertOneAsync(TDocument document, CancellationToken _cancel
 
         /// <inheritdoc />
         public virtual IAsyncCursor<TResult> Watch<TResult>(
-            PipelineDefinition<ChangeStreamOutput<TDocument>, TResult> pipeline,
+            PipelineDefinition<ChangeStreamDocument<TDocument>, TResult> pipeline,
             ChangeStreamOptions options = null,
             CancellationToken cancellationToken = default(CancellationToken))
         {
@@ -505,7 +505,7 @@ public virtual IAsyncCursor<TResult> Watch<TResult>(
 
         /// <inheritdoc />
         public virtual Task<IAsyncCursor<TResult>> WatchAsync<TResult>(
-            PipelineDefinition<ChangeStreamOutput<TDocument>, TResult> pipeline,
+            PipelineDefinition<ChangeStreamDocument<TDocument>, TResult> pipeline,
             ChangeStreamOptions options = null,
             CancellationToken cancellationToken = default(CancellationToken))
         {
diff --git a/src/MongoDB.Driver/MongoCollectionImpl.cs b/src/MongoDB.Driver/MongoCollectionImpl.cs
@@ -374,7 +374,7 @@ public override IFilteredMongoCollection<TDerivedDocument> OfType<TDerivedDocume
         }
 
         public override IAsyncCursor<TResult> Watch<TResult>(
-            PipelineDefinition<ChangeStreamOutput<TDocument>, TResult> pipeline,
+            PipelineDefinition<ChangeStreamDocument<TDocument>, TResult> pipeline,
             ChangeStreamOptions options = null,
             CancellationToken cancellationToken = default(CancellationToken))
         {
@@ -384,7 +384,7 @@ public override IAsyncCursor<TResult> Watch<TResult>(
         }
 
         public override async Task<IAsyncCursor<TResult>> WatchAsync<TResult>(
-            PipelineDefinition<ChangeStreamOutput<TDocument>, TResult> pipeline,
+            PipelineDefinition<ChangeStreamDocument<TDocument>, TResult> pipeline,
             ChangeStreamOptions options = null,
             CancellationToken cancellationToken = default(CancellationToken))
         {
@@ -570,14 +570,14 @@ private BulkMixedWriteOperation CreateBulkWriteOperation(IEnumerable<WriteModel<
         }
 
         private ChangeStreamOperation<TResult> CreateChangeStreamOperation<TResult>(
-            PipelineDefinition<ChangeStreamOutput<TDocument>, TResult> pipeline,
+            PipelineDefinition<ChangeStreamDocument<TDocument>, TResult> pipeline,
             ChangeStreamOptions options)
         {
             options = options ?? new ChangeStreamOptions();
 
-            var changeStreamOutputSerializer = new ChangeStreamOutputSerializer<TDocument>(_documentSerializer);
+            var changeStreamDocumentSerializer = new ChangeStreamDocumentSerializer<TDocument>(_documentSerializer);
             var serializerRegistry = BsonSerializer.SerializerRegistry;
-            var renderedPipeline = pipeline.Render(changeStreamOutputSerializer, serializerRegistry);
+            var renderedPipeline = pipeline.Render(changeStreamDocumentSerializer, serializerRegistry);
 
             var changeStreamOperation = new ChangeStreamOperation<TResult>(
                 _collectionNamespace,
diff --git a/src/MongoDB.Driver/PipelineDefinitionBuilder.cs b/src/MongoDB.Driver/PipelineDefinitionBuilder.cs
@@ -284,7 +284,7 @@ public static PipelineDefinition<TInput, TOutput> BucketAuto<TInput, TIntermedia
         /// <returns>
         /// The fluent aggregate interface.
         /// </returns>
-        public static PipelineDefinition<TInput, ChangeStreamOutput<TIntermediate>> ChangeStream<TInput, TIntermediate>(
+        public static PipelineDefinition<TInput, ChangeStreamDocument<TIntermediate>> ChangeStream<TInput, TIntermediate>(
             this PipelineDefinition<TInput, TIntermediate> pipeline,
             ChangeStreamStageOptions options = null)
         {
diff --git a/src/MongoDB.Driver/PipelineStageDefinitionBuilder.cs b/src/MongoDB.Driver/PipelineStageDefinitionBuilder.cs
@@ -329,13 +329,13 @@ public static PipelineStageDefinition<TInput, TOutput> BucketAuto<TInput, TValue
         /// <typeparam name="TInput">The type of the input documents.</typeparam>
         /// <param name="options">The options.</param>
         /// <returns>The stage.</returns>
-        public static PipelineStageDefinition<TInput, ChangeStreamOutput<TInput>> ChangeStream<TInput>(
+        public static PipelineStageDefinition<TInput, ChangeStreamDocument<TInput>> ChangeStream<TInput>(
             ChangeStreamStageOptions options = null)
         {
             options = options ?? new ChangeStreamStageOptions();
 
             const string operatorName = "$changeStream";
-            var stage = new DelegatedPipelineStageDefinition<TInput, ChangeStreamOutput<TInput>>(
+            var stage = new DelegatedPipelineStageDefinition<TInput, ChangeStreamDocument<TInput>>(
                 operatorName,
                 (s, sr) =>
                 {
@@ -346,8 +346,8 @@ public static PipelineStageDefinition<TInput, ChangeStreamOutput<TInput>> Change
                         renderedOptions.Add("resumeAfter", options.ResumeAfter);
                     }
                     var document = new BsonDocument(operatorName, renderedOptions);
-                    var outputSerializer = new ChangeStreamOutputSerializer<TInput>(s);
-                    return new RenderedPipelineStageDefinition<ChangeStreamOutput<TInput>>(
+                    var outputSerializer = new ChangeStreamDocumentSerializer<TInput>(s);
+                    return new RenderedPipelineStageDefinition<ChangeStreamDocument<TInput>>(
                         operatorName,
                         document,
                         outputSerializer);
diff --git a/tests/MongoDB.Driver.Core.Tests/ChangeStreamDocumentSerializerTests.cs b/tests/MongoDB.Driver.Core.Tests/ChangeStreamDocumentSerializerTests.cs
@@ -28,7 +28,7 @@
 
 namespace MongoDB.Driver
 {
-    public class ChangeStreamOutputSerializerTests
+    public class ChangeStreamDocumentSerializerTests
     {
         [Theory]
         [InlineData("{ _id : { id : 1 }, operationType : \"delete\", ns : { db : \"db\", coll : \"collection\" }, documentKey : { k : 1 } }", "{ id : 1 }", ChangeStreamOperationType.Delete, "db", "collection", "{ k : 1 }", null, null)]
@@ -56,7 +56,7 @@ string expectedFullDocumentJson
             var expectedResumeToken = ParseBsonDocument(expectedResumeTokenJson);
             var expectedUpdateDescription = ParseUpdateDescription(expectedUpdateDescriptionJson);
 
-            ChangeStreamOutput<BsonDocument> result;
+            ChangeStreamDocument<BsonDocument> result;
             using (var reader = new JsonReader(json))
             {
                 var context = BsonDeserializationContext.CreateRoot(reader);
@@ -77,7 +77,7 @@ public void Deserialize_should_return_expected_result_when_value_is_null()
             var subject = CreateSubject();
             var json = "null";
 
-            ChangeStreamOutput<BsonDocument> result;
+            ChangeStreamDocument<BsonDocument> result;
             using (var reader = new JsonReader(json))
             {
                 var context = BsonDeserializationContext.CreateRoot(reader);
@@ -122,7 +122,7 @@ public void Serialize_should_have_expected_result(
             string expectedJson)
         {
             var subject = CreateSubject();
-            var value = new ChangeStreamOutput<BsonDocument>(
+            var value = new ChangeStreamDocument<BsonDocument>(
                 ParseBsonDocument(resumeTokenJson),
                 operationType,
                 CreateCollectionNamespace(databaseName, collectionName),
@@ -146,7 +146,7 @@ public void Serialize_should_have_expected_result(
         public void Serialize_should_have_expected_result_when_value_is_null()
         {
             var subject = CreateSubject();
-            ChangeStreamOutput<BsonDocument> value = null;
+            ChangeStreamDocument<BsonDocument> value = null;
 
             string json;
             using (var textWriter = new StringWriter())
@@ -174,9 +174,9 @@ private CollectionNamespace CreateCollectionNamespace(string databaseName, strin
             }
         }
 
-        private ChangeStreamOutputSerializer<BsonDocument> CreateSubject()
+        private ChangeStreamDocumentSerializer<BsonDocument> CreateSubject()
         {
-            return new ChangeStreamOutputSerializer<BsonDocument>(BsonDocumentSerializer.Instance);
+            return new ChangeStreamDocumentSerializer<BsonDocument>(BsonDocumentSerializer.Instance);
         }
 
         private BsonDocument ParseBsonDocument(string json)
diff --git a/tests/MongoDB.Driver.Core.Tests/Core/Operations/ChangeStreamOperationTests.cs b/tests/MongoDB.Driver.Core.Tests/Core/Operations/ChangeStreamOperationTests.cs
diff --git a/tests/MongoDB.Driver.Core.Tests/MongoDB.Driver.Core.Tests.csproj b/tests/MongoDB.Driver.Core.Tests/MongoDB.Driver.Core.Tests.csproj
diff --git a/tests/MongoDB.Driver.Tests/IMongoCollectionExtensionsTests.cs b/tests/MongoDB.Driver.Tests/IMongoCollectionExtensionsTests.cs
diff --git a/tests/MongoDB.Driver.Tests/MongoCollectionImplTests.cs b/tests/MongoDB.Driver.Tests/MongoCollectionImplTests.cs
diff --git a/tests/MongoDB.Driver.Tests/PipelineDefinitionBuilderTests.cs b/tests/MongoDB.Driver.Tests/PipelineDefinitionBuilderTests.cs
diff --git a/tests/MongoDB.Driver.Tests/PipelineStageDefinitionBuilderTests.cs b/tests/MongoDB.Driver.Tests/PipelineStageDefinitionBuilderTests.cs

Original file line number	Diff line number	Diff line change
`@@ -24,10 +24,10 @@ namespace MongoDB.Driver`
`24`	`24`	`{`
`25`	`25`
`26`	`26`	`/// <summary>`
`27`		`- /// A serializer for ChangeStreamOutput instances.`
	`27`	`+ /// A serializer for ChangeStreamDocument instances.`
`28`	`28`	`/// </summary>`
`29`	`29`	`/// <typeparam name="TDocument">The type of the document.</typeparam>`
`30`		`- public class ChangeStreamOutputSerializer<TDocument> : SealedClassSerializerBase<ChangeStreamOutput<TDocument>>`
	`30`	`+ public class ChangeStreamDocumentSerializer<TDocument> : SealedClassSerializerBase<ChangeStreamDocument<TDocument>>`
`31`	`31`	`{`
`32`	`32`	`#region static`
`33`	`33`	`// private static fields`
`@@ -40,18 +40,18 @@ public class ChangeStreamOutputSerializer<TDocument> : SealedClassSerializerBase`
`40`	`40`
`41`	`41`	`// constructors`
`42`	`42`	`/// <summary>`
`43`		`- /// Initializes a new instance of the <see cref="ChangeStreamOutputSerializer{TDocument}"/> class.`
	`43`	`+ /// Initializes a new instance of the <see cref="ChangeStreamDocumentSerializer{TDocument}"/> class.`
`44`	`44`	`/// </summary>`
`45`	`45`	`/// <param name="documentSerializer">The document serializer.</param>`
`46`		`- public ChangeStreamOutputSerializer(`
	`46`	`+ public ChangeStreamDocumentSerializer(`
`47`	`47`	`IBsonSerializer<TDocument> documentSerializer)`
`48`	`48`	`{`
`49`	`49`	`_documentSerializer = Ensure.IsNotNull(documentSerializer, nameof(documentSerializer));`
`50`	`50`	`}`
`51`	`51`
`52`	`52`	`// public methods`
`53`	`53`	`/// <inheritdoc />`
`54`		`- protected override ChangeStreamOutput<TDocument> DeserializeValue(BsonDeserializationContext context, BsonDeserializationArgs args)`
	`54`	`+ protected override ChangeStreamDocument<TDocument> DeserializeValue(BsonDeserializationContext context, BsonDeserializationArgs args)`
`55`	`55`	`{`
`56`	`56`	`var reader = context.Reader;`
`57`	`57`
`@@ -106,7 +106,7 @@ protected override ChangeStreamOutput<TDocument> DeserializeValue(BsonDeserializ`
`106`	`106`	`}`
`107`	`107`	`reader.ReadEndDocument();`
`108`	`108`
`109`		`- return new ChangeStreamOutput<TDocument>(`
	`109`	`+ return new ChangeStreamDocument<TDocument>(`
`110`	`110`	`resumeToken,`
`111`	`111`	`operationType.Value,`
`112`	`112`	`collectionNamespace,`
`@@ -116,7 +116,7 @@ protected override ChangeStreamOutput<TDocument> DeserializeValue(BsonDeserializ`
`116`	`116`	`}`
`117`	`117`
`118`	`118`	`/// <inheritdoc />`
`119`		`- protected override void SerializeValue(BsonSerializationContext context, BsonSerializationArgs args, ChangeStreamOutput<TDocument> value)`
	`119`	`+ protected override void SerializeValue(BsonSerializationContext context, BsonSerializationArgs args, ChangeStreamDocument<TDocument> value)`
`120`	`120`	`{`
`121`	`121`	`var writer = context.Writer;`
`122`	`122`	`writer.WriteStartDocument();`
Original file line number	Diff line number	Diff line change
`@@ -19,7 +19,7 @@`
`19`	`19`	`namespace MongoDB.Driver`
`20`	`20`	`{`
`21`	`21`	`/// <summary>`
`22`		`- /// An UpdateDescription in a ChangeStreamOutput instance.`
	`22`	`+ /// An UpdateDescription in a ChangeStreamDocument instance.`
`23`	`23`	`/// </summary>`
`24`	`24`	`public sealed class ChangeStreamUpdateDescription`
`25`	`25`	`{`
Original file line number	Diff line number	Diff line change
`@@ -98,7 +98,7 @@ public override IAggregateFluent<TNewResult> BucketAuto<TValue, TNewResult>(`
`98`	`98`	`return WithPipeline(_pipeline.BucketAuto(groupBy, buckets, output, options));`
`99`	`99`	`}`
`100`	`100`
`101`		`- public override IAggregateFluent<ChangeStreamOutput<TResult>> ChangeStream(ChangeStreamStageOptions options = null)`
	`101`	`+ public override IAggregateFluent<ChangeStreamDocument<TResult>> ChangeStream(ChangeStreamStageOptions options = null)`
`102`	`102`	`{`
`103`	`103`	`return WithPipeline(_pipeline.ChangeStream(options));`
`104`	`104`	`}`
Original file line number	Diff line number	Diff line change
`@@ -86,7 +86,7 @@ public virtual IAggregateFluent<TNewResult> BucketAuto<TValue, TNewResult>(`
`86`	`86`	`}`
`87`	`87`
`88`	`88`	`/// <inheritdoc />`
`89`		`- public virtual IAggregateFluent<ChangeStreamOutput<TResult>> ChangeStream(ChangeStreamStageOptions options = null)`
	`89`	`+ public virtual IAggregateFluent<ChangeStreamDocument<TResult>> ChangeStream(ChangeStreamStageOptions options = null)`
`90`	`90`	`{`
`91`	`91`	`throw new NotImplementedException(); // implemented by subclasses`
`92`	`92`	`}`
Original file line number	Diff line number	Diff line change
`@@ -1032,12 +1032,12 @@ public static IFindFluent<TDocument, TDocument> Find<TDocument>(this IMongoColle`
`1032`	`1032`	`/// <returns>`
`1033`	`1033`	`/// A change stream.`
`1034`	`1034`	`/// </returns>`
`1035`		`- public static IAsyncCursor<ChangeStreamOutput<TDocument>> Watch<TDocument>(`
	`1035`	`+ public static IAsyncCursor<ChangeStreamDocument<TDocument>> Watch<TDocument>(`
`1036`	`1036`	`this IMongoCollection<TDocument> collection,`
`1037`	`1037`	`ChangeStreamOptions options = null,`
`1038`	`1038`	`CancellationToken cancellationToken = default(CancellationToken))`
`1039`	`1039`	`{`
`1040`		`- var emptyPipeline = new EmptyPipelineDefinition<ChangeStreamOutput<TDocument>>();`
	`1040`	`+ var emptyPipeline = new EmptyPipelineDefinition<ChangeStreamDocument<TDocument>>();`
`1041`	`1041`	`return collection.Watch(emptyPipeline, options, cancellationToken);`
`1042`	`1042`	`}`
`1043`	`1043`
`@@ -1051,12 +1051,12 @@ public static IAsyncCursor<ChangeStreamOutput<TDocument>> Watch<TDocument>(`
`1051`	`1051`	`/// <returns>`
`1052`	`1052`	`/// A change stream.`
`1053`	`1053`	`/// </returns>`
`1054`		`- public static Task<IAsyncCursor<ChangeStreamOutput<TDocument>>> WatchAsync<TDocument>(`
	`1054`	`+ public static Task<IAsyncCursor<ChangeStreamDocument<TDocument>>> WatchAsync<TDocument>(`
`1055`	`1055`	`this IMongoCollection<TDocument> collection,`
`1056`	`1056`	`ChangeStreamOptions options = null,`
`1057`	`1057`	`CancellationToken cancellationToken = default(CancellationToken))`
`1058`	`1058`	`{`
`1059`		`- var emptyPipeline = new EmptyPipelineDefinition<ChangeStreamOutput<TDocument>>();`
	`1059`	`+ var emptyPipeline = new EmptyPipelineDefinition<ChangeStreamDocument<TDocument>>();`
`1060`	`1060`	`return collection.WatchAsync(emptyPipeline, options, cancellationToken);`
`1061`	`1061`	`}`
`1062`	`1062`	`}`