Did I find the right examples for you? yes no

All Samples(19)  |  Call(8)  |  Derive(0)  |  Import(11)
Exception raised when trying to use a dead or unavailable actor.

src/p/y/Pykka-1.2.0/pykka/actor.py   Pykka(Download)
    import queue as _queue  # noqa
 
from pykka.exceptions import ActorDeadError as _ActorDeadError
from pykka.future import ThreadingFuture as _ThreadingFuture
from pykka.proxy import ActorProxy as _ActorProxy
                else:
                    reply_to.set_exception(_ActorDeadError(
                        '%s stopped before handling the message' %
                        self.actor_ref))
 
        """
        if not self.is_alive():
            raise _ActorDeadError('%s not found' % self)
        self.actor_inbox.put(message)
 

src/p/y/pykka-HEAD/pykka/actor.py   pykka(Download)
    import queue as _queue  # noqa
 
from pykka.exceptions import ActorDeadError as _ActorDeadError
from pykka.future import ThreadingFuture as _ThreadingFuture
from pykka.proxy import ActorProxy as _ActorProxy
                else:
                    reply_to.set_exception(_ActorDeadError(
                        '%s stopped before handling the message' %
                        self.actor_ref))
 
        """
        if not self.is_alive():
            raise _ActorDeadError('%s not found' % self)
        self.actor_inbox.put(message)
 

src/p/y/Pykka-1.2.0/pykka/proxy.py   Pykka(Download)
import collections as _collections
import sys as _sys
 
from pykka.exceptions import ActorDeadError as _ActorDeadError
 
    def __init__(self, actor_ref, attr_path=None):
        if not actor_ref.is_alive():
            raise _ActorDeadError('%s not found' % actor_ref)
        self.actor_ref = actor_ref
        self._actor = actor_ref._actor

src/p/y/pykka-HEAD/pykka/proxy.py   pykka(Download)
import collections as _collections
import sys as _sys
 
from pykka.exceptions import ActorDeadError as _ActorDeadError
 
    def __init__(self, actor_ref, attr_path=None):
        if not actor_ref.is_alive():
            raise _ActorDeadError('%s not found' % actor_ref)
        self.actor_ref = actor_ref
        self._actor = actor_ref._actor

src/x/b/xbmc-addon-watchdog-HEAD/lib/pykka/proxy.py   xbmc-addon-watchdog(Download)
import collections as _collections
import sys as _sys
 
from pykka.exceptions import ActorDeadError as _ActorDeadError
 
    def __init__(self, actor_ref, attr_path=None):
        if not actor_ref.is_alive():
            raise _ActorDeadError('%s not found' % actor_ref)
        self.actor_ref = actor_ref
        # pylint: disable = W0212

src/x/b/xbmc-addon-watchdog-HEAD/lib/pykka/actor.py   xbmc-addon-watchdog(Download)
    # pylint: enable = F0401
 
from pykka.exceptions import ActorDeadError as _ActorDeadError
from pykka.future import ThreadingFuture as _ThreadingFuture
from pykka.proxy import ActorProxy as _ActorProxy
        """
        if not self.is_alive():
            raise _ActorDeadError('%s not found' % self)
        self.actor_inbox.put(message)
 

src/p/y/Pykka-1.2.0/pykka/__init__.py   Pykka(Download)
# flake8: noqa
from pykka.actor import Actor, ActorRef, ThreadingActor
from pykka.exceptions import ActorDeadError, Timeout
from pykka.future import Future, get_all, ThreadingFuture
from pykka.proxy import ActorProxy

src/p/y/pykka-HEAD/pykka/__init__.py   pykka(Download)
# flake8: noqa
from pykka.actor import Actor, ActorRef, ThreadingActor
from pykka.exceptions import ActorDeadError, Timeout
from pykka.future import Future, get_all, ThreadingFuture
from pykka.proxy import ActorProxy

src/x/b/xbmc-addon-watchdog-HEAD/lib/pykka/__init__.py   xbmc-addon-watchdog(Download)
# flake8: noqa
from pykka.actor import Actor, ActorRef, ThreadingActor
from pykka.exceptions import ActorDeadError, Timeout
from pykka.future import Future, get_all, ThreadingFuture
from pykka.proxy import ActorProxy

src/p/y/pykka-HEAD/tests/namespace_test.py   pykka(Download)
    def test_actor_dead_error_import(self):
        from pykka import ActorDeadError as ActorDeadError1
        from pykka.exceptions import ActorDeadError as ActorDeadError2
        self.assertEqual(ActorDeadError1, ActorDeadError2)
 

  1 | 2  Next