@Test(expected = RuntimeException.class) public void testHandlingOfIoException() throws Exception { withIoExceptionDuringLogfileResolution(); tail("/does/not/exist"); }
private void tail(File file, long bytesToTail, Mode mode) { stopTail(); this.tail = new Tail(getRemote(), file, bytesToTail, mode); this.executorService.execute(this.tail); }
TailSocket extends WebSocketAdapter { private void tail(File file, long bytesToTail, Mode mode) { stopTail(); this.tail = new Tail(getRemote(), file, bytesToTail, mode); this.executorService.execute(this.tail); } }
TailSocket extends WebSocketAdapter { private void tail(File file, long bytesToTail, Mode mode) { stopTail(); this.tail = new Tail(getRemote(), file, bytesToTail, mode); this.executorService.execute(this.tail); } TailSocket(LogFiles logFiles); }
TailSocket extends WebSocketAdapter { private void tail(File file, long bytesToTail, Mode mode) { stopTail(); this.tail = new Tail(getRemote(), file, bytesToTail, mode); this.executorService.execute(this.tail); } TailSocket(LogFiles logFiles); @Override void onWebSocketClose(int statusCode, String reason); @Override void onWebSocketText(String message); }
TailSocket extends WebSocketAdapter { private void tail(File file, long bytesToTail, Mode mode) { stopTail(); this.tail = new Tail(getRemote(), file, bytesToTail, mode); this.executorService.execute(this.tail); } TailSocket(LogFiles logFiles); @Override void onWebSocketClose(int statusCode, String reason); @Override void onWebSocketText(String message);  }