code: def data_received(self, data):
          
          if self._on_data:
              self._on_data(data)
              return
          self._queued_data.append(data)
docs: Used to signal `asyncio.Protocol` of incoming data.