code: def socketTextStream(self, hostname, port):
          
          deserializer = TCPDeserializer(self._context)
          tcp_text_stream = TCPTextStream()
          tcp_text_stream.listen(port, hostname)
          self._on_stop_cb.append(tcp_text_stream.stop)
          return DStream(tcp_text_stream, self, deserializer)
docs: Create a TCP socket server.
  
          :param string hostname: Hostname of TCP server.
          :param int port: Port of TCP server.
          :rtype: DStream