@Test public void start() throws Exception { underTest.connect(); verify(underTest).connect(uri); }
void connect() { if (!isConnected()) { session = connect(uri); disposable.update(startKeepAlives()); } }
WebSocket implements AutoCloseable { void connect() { if (!isConnected()) { session = connect(uri); disposable.update(startKeepAlives()); } } }
WebSocket implements AutoCloseable { void connect() { if (!isConnected()) { session = connect(uri); disposable.update(startKeepAlives()); } } WebSocket(
      String username,
      String password,
      URI uri,
      ObjectMapper mapper,
      TLSConfig.Factory tlsConfigFactory,
      long keepAliveSeconds,
      EventHandler eventHandler,
      ErrorHandler errorHandler,
      CloseHandler closeHandler); }
WebSocket implements AutoCloseable { void connect() { if (!isConnected()) { session = connect(uri); disposable.update(startKeepAlives()); } } WebSocket(
      String username,
      String password,
      URI uri,
      ObjectMapper mapper,
      TLSConfig.Factory tlsConfigFactory,
      long keepAliveSeconds,
      EventHandler eventHandler,
      ErrorHandler errorHandler,
      CloseHandler closeHandler); @Override void close(); }
WebSocket implements AutoCloseable { void connect() { if (!isConnected()) { session = connect(uri); disposable.update(startKeepAlives()); } } WebSocket(
      String username,
      String password,
      URI uri,
      ObjectMapper mapper,
      TLSConfig.Factory tlsConfigFactory,
      long keepAliveSeconds,
      EventHandler eventHandler,
      ErrorHandler errorHandler,
      CloseHandler closeHandler); @Override void close();  }