Class AbstractActorSubscriber

  • All Implemented Interfaces:
    Actor, ActorSubscriber

    public abstract class AbstractActorSubscriber
    extends AbstractActor
    implements ActorSubscriber
    Deprecated.
    Use akka.stream.stage.GraphStage instead, it allows for all operations an Actor would and is more type-safe as well as guaranteed to be ReactiveStreams compliant.
    Java API compatible with lambda expressions
    See Also:
    ActorSubscriber
    • Constructor Detail

      • AbstractActorSubscriber

        public AbstractActorSubscriber()
        Deprecated.
    • Method Detail

      • create

        public static <T> org.reactivestreams.Subscriber<T> create​(ActorRef ref)
        Deprecated.
        Java API compatible with lambda expressions: Attach a AbstractActorSubscriber actor as a Subscriber o a Publisher or Flow.
        Parameters:
        ref - (undocumented)
        Returns:
        (undocumented)
      • sender

        public static final ActorRef sender()
        Deprecated.
      • unhandled

        public static void unhandled​(java.lang.Object message)
        Deprecated.
      • getSelf

        public static ActorRef getSelf()
        Deprecated.
      • getSender

        public static ActorRef getSender()
        Deprecated.
      • preStart

        public static void preStart()
                             throws java.lang.Exception
        Deprecated.
        Throws:
        java.lang.Exception
      • postStop

        public static void postStop()
                             throws java.lang.Exception
        Deprecated.
        Throws:
        java.lang.Exception
      • preRestart

        public static void preRestart​(java.lang.Throwable reason,
                                      scala.Option<java.lang.Object> message)
                               throws java.lang.Exception
        Deprecated.
        Throws:
        java.lang.Exception
      • preRestart

        public static void preRestart​(java.lang.Throwable reason,
                                      java.util.Optional<java.lang.Object> message)
                               throws java.lang.Exception
        Deprecated.
        Throws:
        java.lang.Exception
      • postRestart

        public static void postRestart​(java.lang.Throwable reason)
                                throws java.lang.Exception
        Deprecated.
        Throws:
        java.lang.Exception
      • receive

        public static scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receive()
        Deprecated.
      • receiveBuilder

        public static final ReceiveBuilder receiveBuilder()
        Deprecated.
      • context

        public static ActorContext context()
        Deprecated.
      • self

        public static final ActorRef self()
        Deprecated.
      • akka$actor$Actor$_setter_$context_$eq

        protected static void akka$actor$Actor$_setter_$context_$eq​(ActorContext x$1)
        Deprecated.
      • akka$actor$Actor$_setter_$self_$eq

        protected static final void akka$actor$Actor$_setter_$self_$eq​(ActorRef x$1)
        Deprecated.
      • akka$stream$actor$ActorSubscriber$$state

        public static ActorSubscriberState akka$stream$actor$ActorSubscriber$$state()
        Deprecated.
      • akka$stream$actor$ActorSubscriber$$subscription

        public static scala.Option<org.reactivestreams.Subscription> akka$stream$actor$ActorSubscriber$$subscription()
        Deprecated.
      • akka$stream$actor$ActorSubscriber$$subscription_$eq

        public static void akka$stream$actor$ActorSubscriber$$subscription_$eq​(scala.Option<org.reactivestreams.Subscription> x$1)
        Deprecated.
      • akka$stream$actor$ActorSubscriber$$requested

        public static long akka$stream$actor$ActorSubscriber$$requested()
        Deprecated.
      • akka$stream$actor$ActorSubscriber$$requested_$eq

        public static void akka$stream$actor$ActorSubscriber$$requested_$eq​(long x$1)
        Deprecated.
      • akka$stream$actor$ActorSubscriber$$_canceled

        public static boolean akka$stream$actor$ActorSubscriber$$_canceled()
        Deprecated.
      • akka$stream$actor$ActorSubscriber$$_canceled_$eq

        public static void akka$stream$actor$ActorSubscriber$$_canceled_$eq​(boolean x$1)
        Deprecated.
      • requestStrategy

        protected abstract static RequestStrategy requestStrategy()
        Deprecated.
      • canceled

        public static final boolean canceled()
        Deprecated.
      • aroundReceive

        protected static void aroundReceive​(scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receive,
                                            java.lang.Object msg)
        Deprecated.
      • aroundPreStart

        protected static void aroundPreStart()
        Deprecated.
      • aroundPostRestart

        protected static void aroundPostRestart​(java.lang.Throwable reason)
        Deprecated.
      • aroundPreRestart

        protected static void aroundPreRestart​(java.lang.Throwable reason,
                                               scala.Option<java.lang.Object> message)
        Deprecated.
      • aroundPostStop

        protected static void aroundPostStop()
        Deprecated.
      • request

        protected static void request​(long elements)
        Deprecated.
      • cancel

        protected static void cancel()
        Deprecated.
      • remainingRequested

        protected static int remainingRequested()
        Deprecated.
      • akka$stream$actor$ActorSubscriber$_setter_$akka$stream$actor$ActorSubscriber$$state_$eq

        protected abstract static void akka$stream$actor$ActorSubscriber$_setter_$akka$stream$actor$ActorSubscriber$$state_$eq​(ActorSubscriberState x$1)
        Deprecated.