|
21 | 21 | import com.mongodb.MongoCommandException; |
22 | 22 | import com.mongodb.MongoNamespace; |
23 | 23 | import com.mongodb.MongoOperationTimeoutException; |
24 | | -import com.mongodb.MongoSocketReadTimeoutException; |
25 | 24 | import com.mongodb.ReadPreference; |
26 | 25 | import com.mongodb.WriteConcern; |
27 | 26 | import com.mongodb.client.AbstractClientSideOperationsTimeoutProseTest; |
@@ -149,9 +148,7 @@ public void testGridFSUploadViaOpenUploadStreamTimeout() { |
149 | 148 | assertEquals(1, onErrorEvents.size()); |
150 | 149 |
|
151 | 150 | Throwable commandError = onErrorEvents.get(0); |
152 | | - Throwable operationTimeoutErrorCause = commandError.getCause(); |
153 | 151 | assertInstanceOf(MongoOperationTimeoutException.class, commandError); |
154 | | - assertInstanceOf(MongoSocketReadTimeoutException.class, operationTimeoutErrorCause); |
155 | 152 |
|
156 | 153 | CommandFailedEvent chunkInsertFailedEvent = commandListener.getCommandFailedEvent("insert"); |
157 | 154 | assertNotNull(chunkInsertFailedEvent); |
@@ -204,10 +201,7 @@ public void testAbortingGridFsUploadStreamTimeout() throws ExecutionException, I |
204 | 201 | //then |
205 | 202 | Throwable droppedError = droppedErrorFuture.get(TIMEOUT_DURATION.toMillis(), TimeUnit.MILLISECONDS); |
206 | 203 | Throwable commandError = droppedError.getCause(); |
207 | | - Throwable operationTimeoutErrorCause = commandError.getCause(); |
208 | | - |
209 | 204 | assertInstanceOf(MongoOperationTimeoutException.class, commandError); |
210 | | - assertInstanceOf(MongoSocketReadTimeoutException.class, operationTimeoutErrorCause); |
211 | 205 |
|
212 | 206 | CommandFailedEvent deleteFailedEvent = commandListener.getCommandFailedEvent("delete"); |
213 | 207 | assertNotNull(deleteFailedEvent); |
|
0 commit comments