410 assertEquals(listener.invocations(), List.of(onOpen(ws))); |
410 assertEquals(listener.invocations(), List.of(onOpen(ws))); |
411 MockTransport<WebSocket> transport = (MockTransport<WebSocket>) ws.transport(); |
411 MockTransport<WebSocket> transport = (MockTransport<WebSocket>) ws.transport(); |
412 assertEquals(transport.invocations().size(), 3); // 6 minus 3 that were not accepted |
412 assertEquals(transport.invocations().size(), 3); // 6 minus 3 that were not accepted |
413 } |
413 } |
414 |
414 |
415 private static <T> CompletableFuture<T> seconds(long sec, T result) { |
415 private static <T> CompletableFuture<T> seconds(long val, T result) { |
416 return new CompletableFuture<T>() |
416 return new CompletableFuture<T>() |
417 .completeOnTimeout(result, sec, TimeUnit.SECONDS); |
417 .completeOnTimeout(result, val, TimeUnit.SECONDS); |
418 } |
418 } |
419 |
419 |
420 private static <T> CompletableFuture<T> millis(long sec, T result) { |
420 private static <T> CompletableFuture<T> millis(long val, T result) { |
421 return new CompletableFuture<T>() |
421 return new CompletableFuture<T>() |
422 .completeOnTimeout(result, sec, TimeUnit.MILLISECONDS); |
422 .completeOnTimeout(result, val, TimeUnit.MILLISECONDS); |
423 } |
423 } |
424 |
424 |
425 private static <T> CompletableFuture<T> now(T result) { |
425 private static <T> CompletableFuture<T> now(T result) { |
426 return CompletableFuture.completedFuture(result); |
426 return CompletableFuture.completedFuture(result); |
427 } |
427 } |