Interface DeathWatch

    • Method Detail

      • addressTerminated

        void addressTerminated​(Address address)
      • checkWatchingSame

        void checkWatchingSame​(InternalActorRef ref,
                               scala.Option<java.lang.Object> newMessage)
        Call only if it was checked before that `watching contains ref`
      • isWatching

        boolean isWatching​(ActorRef ref)
      • maintainAddressTerminatedSubscription

        <T> T maintainAddressTerminatedSubscription​(ActorRef change,
                                                    scala.Function0<T> block)
        Starts subscription to AddressTerminated if not already subscribing and the block adds a non-local ref to watching or watchedBy. Ends subscription to AddressTerminated if subscribing and the block removes the last non-local ref from watching and watchedBy.
        Parameters:
        change - (undocumented)
        block - (undocumented)
        Returns:
        (undocumented)
      • maintainAddressTerminatedSubscription$default$1

        <T> ActorRef maintainAddressTerminatedSubscription$default$1()
      • receivedTerminated

        void receivedTerminated​(Terminated t)
      • removeFromMap

        <T> scala.collection.immutable.Map<ActorRef,​T> removeFromMap​(ActorRef subject,
                                                                           scala.collection.immutable.Map<ActorRef,​T> map)
      • removeFromSet

        scala.collection.immutable.Set<ActorRef> removeFromSet​(ActorRef subject,
                                                               scala.collection.immutable.Set<ActorRef> set)
      • subscribeAddressTerminated

        void subscribeAddressTerminated()
      • tellWatchersWeDied

        void tellWatchersWeDied()
      • terminatedQueuedFor

        void terminatedQueuedFor​(ActorRef subject)
      • terminatedQueued_$eq

        void terminatedQueued_$eq​(scala.collection.immutable.Set<ActorRef> x$1)
      • unsubscribeAddressTerminated

        void unsubscribeAddressTerminated()
      • unwatchWatchedActors

        void unwatchWatchedActors​(Actor actor)
      • updateWatching

        void updateWatching​(InternalActorRef ref,
                            scala.Option<java.lang.Object> newMessage)
      • watchedActorTerminated

        void watchedActorTerminated​(ActorRef actor,
                                    boolean existenceConfirmed,
                                    boolean addressTerminated)
        When this actor is watching the subject of Terminated message it will be propagated to user's receive.
        Parameters:
        actor - (undocumented)
        existenceConfirmed - (undocumented)
        addressTerminated - (undocumented)
      • watchedBy_$eq

        void watchedBy_$eq​(scala.collection.immutable.Set<ActorRef> x$1)
      • watchingContains

        boolean watchingContains​(ActorRef subject)
      • watchingGet

        scala.Option<scala.Option<java.lang.Object>> watchingGet​(ActorRef subject)
      • watching_$eq

        void watching_$eq​(scala.collection.immutable.Map<ActorRef,​scala.Option<java.lang.Object>> x$1)