code: public StreamingConnection createConnection() throws IOException, InterruptedException {
          StreamingConnectionImpl conn = new StreamingConnectionImpl(clusterId, clientId, options());
          conn.connect();
          return conn;
      }
docs: Creates an active connection to a NATS Streaming server.
  
  @return the StreamingConnection.
  @throws IOException          if a StreamingConnection cannot be established for some reason.
  @throws InterruptedException if the calling thread is interrupted before the connection can
  be established