code: def receive(self):
          
          try:
              return self.socket.recv(self.__recv_bytes)
          except socket.error:
              _, e, _ = sys.exc_info()
              if get_errno(e) in (errno.EAGAIN, errno.EINTR):
                  log.debug("socket read interrupted, restarting")
                  raise exception.InterruptedException()
              if self.is_connected():
                  raise
docs: :rtype: bytes