Class UntypedActorPublisher<T>

  • All Implemented Interfaces:
    Actor, ActorPublisher<T>

    public abstract class UntypedActorPublisher<T>
    extends UntypedActor
    implements ActorPublisher<T>
    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. Since 2.5.0.
    Java API
    See Also:
    ActorPublisher
    • Constructor Detail

      • UntypedActorPublisher

        public UntypedActorPublisher()
        Deprecated.
    • Method Detail

      • create

        public static <T> org.reactivestreams.Publisher<T> create​(ActorRef ref)
        Deprecated.
        Java API: Create a Publisher backed by a UntypedActorPublisher actor. It can be attached to a Subscriber or be used as an input source for a Flow.
        Parameters:
        ref - (undocumented)
        Returns:
        (undocumented)
      • sender

        public static final ActorRef sender()
        Deprecated.
      • onReceive

        public abstract static void onReceive​(java.lang.Object message)
                                       throws java.lang.Throwable
        Deprecated.
        Throws:
        java.lang.Throwable
      • 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
      • postRestart

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

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

        public static void unhandled​(java.lang.Object message)
        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$ActorPublisher$$state

        public static ActorPublisherState akka$stream$actor$ActorPublisher$$state()
        Deprecated.
      • akka$stream$actor$ActorPublisher$$subscriber

        public static org.reactivestreams.Subscriber<java.lang.Object> akka$stream$actor$ActorPublisher$$subscriber()
        Deprecated.
      • akka$stream$actor$ActorPublisher$$subscriber_$eq

        public static void akka$stream$actor$ActorPublisher$$subscriber_$eq​(org.reactivestreams.Subscriber<java.lang.Object> x$1)
        Deprecated.
      • akka$stream$actor$ActorPublisher$$demand

        public static long akka$stream$actor$ActorPublisher$$demand()
        Deprecated.
      • akka$stream$actor$ActorPublisher$$demand_$eq

        public static void akka$stream$actor$ActorPublisher$$demand_$eq​(long x$1)
        Deprecated.
      • akka$stream$actor$ActorPublisher$$lifecycleState

        public static akka.stream.actor.ActorPublisher.Internal.LifecycleState akka$stream$actor$ActorPublisher$$lifecycleState()
        Deprecated.
      • akka$stream$actor$ActorPublisher$$lifecycleState_$eq

        public static void akka$stream$actor$ActorPublisher$$lifecycleState_$eq​(akka.stream.actor.ActorPublisher.Internal.LifecycleState x$1)
        Deprecated.
      • akka$stream$actor$ActorPublisher$$scheduledSubscriptionTimeout

        public static Cancellable akka$stream$actor$ActorPublisher$$scheduledSubscriptionTimeout()
        Deprecated.
      • akka$stream$actor$ActorPublisher$$scheduledSubscriptionTimeout_$eq

        public static void akka$stream$actor$ActorPublisher$$scheduledSubscriptionTimeout_$eq​(Cancellable x$1)
        Deprecated.
      • subscriptionTimeout

        public static scala.concurrent.duration.Duration subscriptionTimeout()
        Deprecated.
      • isActive

        public static final boolean isActive()
        Deprecated.
      • totalDemand

        public static final long totalDemand()
        Deprecated.
      • isCompleted

        public static final boolean isCompleted()
        Deprecated.
      • isErrorEmitted

        public static final boolean isErrorEmitted()
        Deprecated.
      • isCanceled

        public static final boolean isCanceled()
        Deprecated.
      • onNext

        public static void onNext​(T element)
        Deprecated.
      • onComplete

        public static void onComplete()
        Deprecated.
      • onCompleteThenStop

        public static void onCompleteThenStop()
        Deprecated.
      • onError

        public static void onError​(java.lang.Throwable cause)
        Deprecated.
      • onErrorThenStop

        public static void onErrorThenStop​(java.lang.Throwable cause)
        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.
      • aroundPreRestart

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

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

        protected static void aroundPostStop()
        Deprecated.
      • akka$stream$actor$ActorPublisher$_setter_$akka$stream$actor$ActorPublisher$$state_$eq

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