He escrito un método que le pide al usuario que presione Intro para continuar y se agota el tiempo después de un tiempo. Tengo dificultades para escribir pruebas de Junit para este método usando Mockito. A continuación se muestra el método.
private static final ExecutorService l = Executors.newFixedThreadPool(1); private static String getUserInputWithTimeout(int timeout) { Callable<String> k = () -> new Scanner(System.in).nextLine(); LocalDateTime start = LocalDateTime.now(); Future<String> g = l.submit(k); while (ChronoUnit.SECONDS.between(start, LocalDateTime.now()) < timeout) { if (g.isDone()) { try { String choice = g.get(); return choice; } catch (InterruptedException | ExecutionException | IllegalArgumentException e) { logger.error("ERROR", e); g = l.submit(k); } } } logger.info("Timeout..."); g.cancel(true); return null; }Intenté burlarme de Callable y Future, pero como este método los crea localmente, crearlos en Test no tiene ningún impacto.
Intenté algunas cosas pero no funcionó como esperaba, podría estar haciéndolo mal.
@Test public void testgetUserInputWithUserInput() throws Exception { Scanner scanner = new Scanner(System.in); Callable<String> callable = PowerMockito.mock(Callable.class); ExecutorService executorServiceMock = PowerMockito.mock(ExecutorService.class); Future<String> futureMock = PowerMockito.mock(Future.class); when(executorServiceMock.submit(any(Callable.class))).thenReturn(futureMock); assertEquals("", getUserInputWithTimeout(3)); }Diría que necesita cambiar ligeramente su método, sacar el objeto invocable del método y pasarlo como parámetro, esto debería resolver su problema con la burla.
private static final ExecutorService l = Executors.newFixedThreadPool(1); private static String getUserInputWithTimeout(int timeout, Callable<String> k) { LocalDateTime start = LocalDateTime.now(); Future<String> g = l.submit(k); while (ChronoUnit.SECONDS.between(start, LocalDateTime.now()) < timeout) { if (g.isDone()) { try { String choice = g.get(); return choice; } catch (InterruptedException | ExecutionException | IllegalArgumentException e) { logger.error("ERROR", e); g = l.submit(k); } } } logger.info("Timeout..."); g.cancel(true); return null; }Sus pruebas deben verse como a continuación:
@Test public void testgetUserInputWithUserInput() throws Exception { String ENTER = " "; System.setIn(new ByteArrayInputStream(ENTER.getBytes())); Callable<String> callable = () -> new Scanner(System.in).nextLine(); assertEquals(ENTER, getUserInputWithTimeout(5, callable)); }