Skip to content

Commit 88f21f3

Browse files
committed
Don't set the timeoutMode on change streams as it impedes legacy options
1 parent 0c1512e commit 88f21f3

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

driver-core/src/main/com/mongodb/internal/operation/ChangeStreamOperation.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@
1717
package com.mongodb.internal.operation;
1818

1919
import com.mongodb.MongoNamespace;
20-
import com.mongodb.client.cursor.TimeoutMode;
2120
import com.mongodb.client.model.Collation;
2221
import com.mongodb.client.model.changestream.FullDocument;
2322
import com.mongodb.client.model.changestream.FullDocumentBeforeChange;
@@ -72,7 +71,7 @@ public ChangeStreamOperation(final MongoNamespace namespace, final FullDocument
7271
final FullDocumentBeforeChange fullDocumentBeforeChange, final List<BsonDocument> pipeline, final Decoder<T> decoder,
7372
final ChangeStreamLevel changeStreamLevel) {
7473
this.wrapped = new AggregateOperationImpl<>(namespace, pipeline, RAW_BSON_DOCUMENT_CODEC, getAggregateTarget(),
75-
getPipelineCreator()).timeoutMode(TimeoutMode.ITERATION);
74+
getPipelineCreator());
7675
this.fullDocument = notNull("fullDocument", fullDocument);
7776
this.fullDocumentBeforeChange = notNull("fullDocumentBeforeChange", fullDocumentBeforeChange);
7877
this.decoder = notNull("decoder", decoder);

0 commit comments

Comments
 (0)