code: public static Observable<String> from(final String host, final int port, long quietTimeoutMs,
              long reconnectDelayMs, Charset charset, Scheduler scheduler) {
          // delay connect by delayMs so that if server closes
          // stream on every connect we won't be in a mad loop of
          // failing connections
          return from(socketCreator(host, port, (int) quietTimeoutMs), quietTimeoutMs,
                  reconnectDelayMs, charset, scheduler); //
      }
docs: Returns an Observable sequence of strings (not lines) from the given host
  and port. If the stream is quiet for <code>quietTimeoutMs</code> then a
  reconnect will be attempted. Note that this is a good idea with TCPIP
  connections as for instance a firewall can simply drop a quiet connection
  without the client being aware of it. If any exception occurs a reconnect
  will be attempted after <code>reconnectDelayMs</code>. If the socket is
  closed by the server (the end of the input stream is reached) then a
  reconnect is attempted after <code>reconnectDelayMs</code>.
  
  @param hostPort
  @return Observable sequence of strings (not lines).