code: def on_receive(self, broker):
          
          buf = self.receive_side.read()
          if not buf:
              return self.on_disconnect(broker)
  
          self.buf += buf.decode('utf-8', 'replace')
          while u'\n' in self.buf:
              lines = self.buf.split('\n')
              self.buf = lines[-1]
              for line in lines[:-1]:
                  LOG.debug('%s: %s', self.stream.name, line.rstrip())
docs: This handler is only called after the stream is registered with the IO
          loop, the descriptor is manually read/written by _connect_bootstrap()
          prior to that.