|
25 | 25 | import com.mongodb.connection.ServerDescription; |
26 | 26 | import com.mongodb.connection.ServerId; |
27 | 27 | import com.mongodb.internal.connection.OperationContext.ServerDeprioritization; |
| 28 | +import com.mongodb.internal.mockito.MongoMockito; |
28 | 29 | import com.mongodb.selector.ServerSelector; |
29 | 30 | import org.junit.jupiter.api.BeforeEach; |
30 | 31 | import org.junit.jupiter.api.Named; |
31 | 32 | import org.junit.jupiter.api.Test; |
32 | 33 | import org.junit.jupiter.params.ParameterizedTest; |
33 | 34 | import org.junit.jupiter.params.provider.Arguments; |
34 | 35 | import org.junit.jupiter.params.provider.MethodSource; |
| 36 | +import org.mockito.Mockito; |
35 | 37 |
|
36 | 38 | import java.util.List; |
37 | 39 | import java.util.function.Supplier; |
|
48 | 50 | import static org.junit.jupiter.api.Assertions.assertDoesNotThrow; |
49 | 51 | import static org.junit.jupiter.api.Assertions.assertEquals; |
50 | 52 | import static org.junit.jupiter.params.provider.Arguments.of; |
| 53 | +import static org.mockito.ArgumentMatchers.any; |
51 | 54 |
|
52 | 55 | final class ServerDeprioritizationTest { |
53 | 56 | private static final ServerDescription SERVER_A = serverDescription("a"); |
@@ -167,9 +170,9 @@ void selectWithRetryWhenWrappedReturnsEmpty(final List<ServerDescription> select |
167 | 170 | }) |
168 | 171 | ); |
169 | 172 | assertAll( |
170 | | - () -> assertEquals(selectorResult, serverDeprioritization.applyDeprioritization(selectorSupplier.get()).select(SHARDED_CLUSTER)), |
171 | | - () -> assertEquals(selectorResult, serverDeprioritization.applyDeprioritization(selectorSupplier.get()).select(REPLICA_SET_CLUSTER)), |
172 | | - () -> assertEquals(selectorResult, serverDeprioritization.applyDeprioritization(selectorSupplier.get()).select(UNKNOWN_CLUSTER)) |
| 173 | + () -> assertEquals(selectorResult, serverDeprioritization.apply(selectorSupplier.get()).select(SHARDED_CLUSTER)), |
| 174 | + () -> assertEquals(selectorResult, serverDeprioritization.apply(selectorSupplier.get()).select(REPLICA_SET_CLUSTER)), |
| 175 | + () -> assertEquals(selectorResult, serverDeprioritization.apply(selectorSupplier.get()).select(UNKNOWN_CLUSTER)) |
173 | 176 | ); |
174 | 177 | } |
175 | 178 |
|
|
0 commit comments