Skip to content

Commit b18439e

Browse files
authored
Normalize async and sync ClientSideOperationTimeoutProseTest (#1800)
1 parent 81f74cc commit b18439e

File tree

1 file changed

+0
-6
lines changed

1 file changed

+0
-6
lines changed

driver-reactive-streams/src/test/functional/com/mongodb/reactivestreams/client/ClientSideOperationTimeoutProseTest.java

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@
2121
import com.mongodb.MongoCommandException;
2222
import com.mongodb.MongoNamespace;
2323
import com.mongodb.MongoOperationTimeoutException;
24-
import com.mongodb.MongoSocketReadTimeoutException;
2524
import com.mongodb.ReadPreference;
2625
import com.mongodb.WriteConcern;
2726
import com.mongodb.client.AbstractClientSideOperationsTimeoutProseTest;
@@ -149,9 +148,7 @@ public void testGridFSUploadViaOpenUploadStreamTimeout() {
149148
assertEquals(1, onErrorEvents.size());
150149

151150
Throwable commandError = onErrorEvents.get(0);
152-
Throwable operationTimeoutErrorCause = commandError.getCause();
153151
assertInstanceOf(MongoOperationTimeoutException.class, commandError);
154-
assertInstanceOf(MongoSocketReadTimeoutException.class, operationTimeoutErrorCause);
155152

156153
CommandFailedEvent chunkInsertFailedEvent = commandListener.getCommandFailedEvent("insert");
157154
assertNotNull(chunkInsertFailedEvent);
@@ -204,10 +201,7 @@ public void testAbortingGridFsUploadStreamTimeout() throws ExecutionException, I
204201
//then
205202
Throwable droppedError = droppedErrorFuture.get(TIMEOUT_DURATION.toMillis(), TimeUnit.MILLISECONDS);
206203
Throwable commandError = droppedError.getCause();
207-
Throwable operationTimeoutErrorCause = commandError.getCause();
208-
209204
assertInstanceOf(MongoOperationTimeoutException.class, commandError);
210-
assertInstanceOf(MongoSocketReadTimeoutException.class, operationTimeoutErrorCause);
211205

212206
CommandFailedEvent deleteFailedEvent = commandListener.getCommandFailedEvent("delete");
213207
assertNotNull(deleteFailedEvent);

0 commit comments

Comments
 (0)