python/ray/_private/gcs_pubsub.py
def poll(self, timeout=None) -> Optional[bytes]:
        """Polls for new actor messages.

        Returns:
            A byte string of function key.
            None if polling times out or subscriber closed.
        """
        with self._lock:
            self._poll_locked(timeout=timeout)
            return self._pop_actor(self._queue)
Polls for new actor messages.

        Returns:
            A byte string of function key.
            None if polling times out or subscriber closed.
        
Polls for new actor messages.
Polls for new actor messages .
def poll(self, timeout=None) -> Optional[bytes]:
        with self._lock:
            self._poll_locked(timeout=timeout)
            return self._pop_actor(self._queue)
def poll ( self , timeout = None ) -> Optional [ bytes ] : with self . _lock : self . _poll_locked ( timeout = timeout ) return self . _pop_actor ( self . _queue )
Polls for new actor messages.
Polls for new actor messages .
"""Polls for new actor messages.

        Returns:
            A byte string of function key.
            None if polling times out or subscriber closed.
        """
A byte string of function key.
None if polling times out or subscriber closed.
A byte string of function key . None if polling times out or subscriber closed .
self
timeout