code: def _process_incoming_data(self):
          
          while self._running.is_set():
              if self.poller.is_ready:
                  self.data_in += self._receive()
                  self.data_in = self._on_read_impl(self.data_in)
docs: Retrieve and process any incoming data.
  
          :return: