@Test(groups = SMALL) public void testWhenPollerStopsInvokesTheDisconnectMethodOfTheEventSource() throws InterruptedException { startPollingThread(); poller.stop(); sleep(100L); verify(evtSource).disconnect(); }
void stop() { runnable = false; }
EventPoller implements Runnable { void stop() { runnable = false; } }
EventPoller implements Runnable { void stop() { runnable = false; } EventPoller(EventSource eventSource, EventChannel<T> eventChannel); }
EventPoller implements Runnable { void stop() { runnable = false; } EventPoller(EventSource eventSource, EventChannel<T> eventChannel); void run(); }
EventPoller implements Runnable { void stop() { runnable = false; } EventPoller(EventSource eventSource, EventChannel<T> eventChannel); void run();  }