code: def _receive(self):
          
          data_in = EMPTY_BUFFER
          try:
              data_in = self._read_from_socket()
          except socket.timeout:
              pass
          except (IOError, OSError) as why:
              if why.args[0] not in (EWOULDBLOCK, EAGAIN):
                  self._exceptions.append(AMQPConnectionError(why))
                  self._running.clear()
          return data_in
docs: Receive any incoming socket data.
  
              If an error is thrown, handle it and return an empty string.
  
          :return: data_in
          :rtype: bytes