From 1ca63a31b6d0454b4d7958e959f9c57409fcf1b7 Mon Sep 17 00:00:00 2001 From: Ross Lawley Date: Mon, 1 Sep 2025 16:19:01 +0100 Subject: [PATCH] Normalize async and sync ClientSideOperationTimeoutProseTest --- .../client/ClientSideOperationTimeoutProseTest.java | 6 ------ 1 file changed, 6 deletions(-) diff --git a/driver-reactive-streams/src/test/functional/com/mongodb/reactivestreams/client/ClientSideOperationTimeoutProseTest.java b/driver-reactive-streams/src/test/functional/com/mongodb/reactivestreams/client/ClientSideOperationTimeoutProseTest.java index fedd8e0efc4..0262fc397b9 100644 --- a/driver-reactive-streams/src/test/functional/com/mongodb/reactivestreams/client/ClientSideOperationTimeoutProseTest.java +++ b/driver-reactive-streams/src/test/functional/com/mongodb/reactivestreams/client/ClientSideOperationTimeoutProseTest.java @@ -21,7 +21,6 @@ import com.mongodb.MongoCommandException; import com.mongodb.MongoNamespace; import com.mongodb.MongoOperationTimeoutException; -import com.mongodb.MongoSocketReadTimeoutException; import com.mongodb.ReadPreference; import com.mongodb.WriteConcern; import com.mongodb.client.AbstractClientSideOperationsTimeoutProseTest; @@ -149,9 +148,7 @@ public void testGridFSUploadViaOpenUploadStreamTimeout() { assertEquals(1, onErrorEvents.size()); Throwable commandError = onErrorEvents.get(0); - Throwable operationTimeoutErrorCause = commandError.getCause(); assertInstanceOf(MongoOperationTimeoutException.class, commandError); - assertInstanceOf(MongoSocketReadTimeoutException.class, operationTimeoutErrorCause); CommandFailedEvent chunkInsertFailedEvent = commandListener.getCommandFailedEvent("insert"); assertNotNull(chunkInsertFailedEvent); @@ -204,10 +201,7 @@ public void testAbortingGridFsUploadStreamTimeout() throws ExecutionException, I //then Throwable droppedError = droppedErrorFuture.get(TIMEOUT_DURATION.toMillis(), TimeUnit.MILLISECONDS); Throwable commandError = droppedError.getCause(); - Throwable operationTimeoutErrorCause = commandError.getCause(); - assertInstanceOf(MongoOperationTimeoutException.class, commandError); - assertInstanceOf(MongoSocketReadTimeoutException.class, operationTimeoutErrorCause); CommandFailedEvent deleteFailedEvent = commandListener.getCommandFailedEvent("delete"); assertNotNull(deleteFailedEvent);