@Test public void disposes_executor_when_stopping() throws Exception { wsEventListener.stop(); verify(fiber).dispose(); }
public void stop() { executor.dispose(); }
WsEventListener implements StateTransitionListener, RaftProtocolListener { public void stop() { executor.dispose(); } }
WsEventListener implements StateTransitionListener, RaftProtocolListener { public void stop() { executor.dispose(); } WsEventListener();  WsEventListener(Fiber fiber); }
WsEventListener implements StateTransitionListener, RaftProtocolListener { public void stop() { executor.dispose(); } WsEventListener();  WsEventListener(Fiber fiber); void start(); void stop(); @Override void changeState(@Nonnull final Raft context, @Nullable final Raft.StateType from, @Nonnull final Raft.StateType to); @Override void invalidTransition(@Nonnull final Raft context, @Nonnull final Raft.StateType actual,
                                @Nullable final Raft.StateType expected); @Override void stop(@Nonnull final Raft raft); @Override void init(final Raft raft); @Override void appendEntries(@Nonnull final Raft raft, @Nonnull final AppendEntries entries); @Override void requestVote(@Nonnull final Raft raft, @Nonnull final RequestVote vote); @Override void commit(@Nonnull final Raft raft, @Nonnull final byte[] operation); void addClient(Listener listener); void removeClient(Listener listener); void error(EventSocket socket, Throwable error); }
WsEventListener implements StateTransitionListener, RaftProtocolListener { public void stop() { executor.dispose(); } WsEventListener();  WsEventListener(Fiber fiber); void start(); void stop(); @Override void changeState(@Nonnull final Raft context, @Nullable final Raft.StateType from, @Nonnull final Raft.StateType to); @Override void invalidTransition(@Nonnull final Raft context, @Nonnull final Raft.StateType actual,
                                @Nullable final Raft.StateType expected); @Override void stop(@Nonnull final Raft raft); @Override void init(final Raft raft); @Override void appendEntries(@Nonnull final Raft raft, @Nonnull final AppendEntries entries); @Override void requestVote(@Nonnull final Raft raft, @Nonnull final RequestVote vote); @Override void commit(@Nonnull final Raft raft, @Nonnull final byte[] operation); void addClient(Listener listener); void removeClient(Listener listener); void error(EventSocket socket, Throwable error);  }