|
42 | 42 | import io.helidon.config.Config;
|
43 | 43 | import io.helidon.config.MapConfigSource;
|
44 | 44 | import io.helidon.config.spi.ConfigSource;
|
| 45 | +import io.helidon.webserver.grpc.GrpcService; |
45 | 46 | import java.io.IOException;
|
46 | 47 | import java.nio.file.Files;
|
47 | 48 | import java.nio.file.Path;
|
48 | 49 | import java.security.NoSuchAlgorithmException;
|
49 | 50 | import java.util.List;
|
50 | 51 | import java.util.Map;
|
51 | 52 | import java.util.Optional;
|
52 |
| -import java.util.function.BiConsumer; |
53 |
| - |
54 |
| -import io.helidon.webserver.Routing; |
55 |
| -import io.helidon.webserver.grpc.GrpcService; |
56 | 53 | import org.junit.jupiter.api.AfterEach;
|
57 | 54 | import org.junit.jupiter.api.BeforeEach;
|
58 | 55 | import org.junit.jupiter.api.Test;
|
@@ -266,9 +263,14 @@ public void testUpdateInvokesRoutingWithLambdas() {
|
266 | 263 | GrpcService.Routing routing = mock(GrpcService.Routing.class);
|
267 | 264 | blockStreamService.update(routing);
|
268 | 265 |
|
269 |
| - verify(routing, timeout(50).times(1)).bidi(eq(CLIENT_STREAMING_METHOD_NAME), any(ServerCalls.BidiStreamingMethod.class)); |
270 |
| - verify(routing, timeout(50).times(1)).serverStream(eq(SERVER_STREAMING_METHOD_NAME), any(ServerCalls.ServerStreamingMethod.class)); |
271 |
| - verify(routing, timeout(50).times(1)).unary(eq(SINGLE_BLOCK_METHOD_NAME), any(ServerCalls.UnaryMethod.class)); |
| 266 | + verify(routing, timeout(50).times(1)) |
| 267 | + .bidi(eq(CLIENT_STREAMING_METHOD_NAME), any(ServerCalls.BidiStreamingMethod.class)); |
| 268 | + verify(routing, timeout(50).times(1)) |
| 269 | + .serverStream( |
| 270 | + eq(SERVER_STREAMING_METHOD_NAME), |
| 271 | + any(ServerCalls.ServerStreamingMethod.class)); |
| 272 | + verify(routing, timeout(50).times(1)) |
| 273 | + .unary(eq(SINGLE_BLOCK_METHOD_NAME), any(ServerCalls.UnaryMethod.class)); |
272 | 274 | }
|
273 | 275 |
|
274 | 276 | private BlockPersistenceHandler<BlockItem, Block> buildBlockPersistenceHandler()
|
|
0 commit comments