Package akka.stream.actor

Interface ActorPublisher<T>

    • Method Detail

      • super$aroundReceive

        void super$aroundReceive​(scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receive,
                         java.lang.Object msg)
        Deprecated.
        INTERNAL API
        Parameters:
        receive - (undocumented)
        msg - (undocumented)

      • super$aroundPreStart

        void super$aroundPreStart()
        Deprecated.
        INTERNAL API

      • super$aroundPreRestart

        void super$aroundPreRestart​(java.lang.Throwable reason,
                            scala.Option<java.lang.Object> message)
        Deprecated.
        INTERNAL API
        Parameters:
        reason - (undocumented)
        message - (undocumented)

      • super$aroundPostRestart

        void super$aroundPostRestart​(java.lang.Throwable reason)
        Deprecated.
        INTERNAL API
        Parameters:
        reason - (undocumented)

      • super$aroundPostStop

        void super$aroundPostStop()
        Deprecated.
        INTERNAL API

      • subscriber_$eq

        void subscriber_$eq​(org.reactivestreams.Subscriber<java.lang.Object> x$1)
        Deprecated.

      • demand_$eq

        void demand_$eq​(long x$1)
        Deprecated.

      • lifecycleState_$eq

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

      • scheduledSubscriptionTimeout_$eq

        void scheduledSubscriptionTimeout_$eq​(Cancellable x$1)
        Deprecated.

      • subscriptionTimeout

        scala.concurrent.duration.Duration subscriptionTimeout()
        Deprecated.
        Subscription timeout after which this actor will become Canceled and reject any incoming "late" subscriber.

        The actor will receive an SubscriptionTimeoutExceeded message upon which it MUST react by performing all necessary cleanup and stopping itself.

        Use this feature in order to avoid leaking actors when you suspect that this Publisher may never get subscribed to by some Subscriber.

        Returns:
        (undocumented)

      • isActive

        boolean isActive()
        Deprecated.
        The state when the publisher is active, i.e. before the subscriber is attached and when an subscriber is attached. It is allowed to call onComplete() and onError(java.lang.Throwable) in this state. It is allowed to call onNext(T) in this state when totalDemand() is greater than zero.
        Returns:
        (undocumented)

      • totalDemand

        long totalDemand()
        Deprecated.
        Total number of requested elements from the stream subscriber. This actor automatically keeps tracks of this amount based on incoming request messages and outgoing onNext.
        Returns:
        (undocumented)

      • isCanceled

        boolean isCanceled()
        Deprecated.
        The state after the stream subscriber has canceled the subscription. It is allowed to call onNext(T), onError(java.lang.Throwable), and onComplete() in this state, but the calls will not perform anything.
        Returns:
        (undocumented)

      • onNext

        void onNext​(T element)
        Deprecated.
        Send an element to the stream subscriber. You are allowed to send as many elements as have been requested by the stream subscriber. This amount can be inquired with totalDemand(). It is only allowed to use onNext when isActive and totalDemand > 0, otherwise onNext will throw IllegalStateException.
        Parameters:
        element - (undocumented)

      • onCompleteThenStop

        void onCompleteThenStop()
        Deprecated.
        Complete the stream. After that you are not allowed to call onNext(T), onError(java.lang.Throwable) and onComplete().

        After signaling completion the Actor will then stop itself as it has completed the protocol. When onComplete() is called before any Subscriber has had the chance to subscribe to this ActorPublisher the completion signal (and therefore stopping of the Actor as well) will be delayed until such Subscriber arrives.

      • onErrorThenStop

        void onErrorThenStop​(java.lang.Throwable cause)
        Deprecated.
        Terminate the stream with failure. After that you are not allowed to call onNext(T), onError(java.lang.Throwable) and onComplete().

        After signaling the Error the Actor will then stop itself as it has completed the protocol. When onError(java.lang.Throwable) is called before any Subscriber has had the chance to subscribe to this ActorPublisher the error signal (and therefore stopping of the Actor as well) will be delayed until such Subscriber arrives.

        Parameters:
        cause - (undocumented)

      • aroundReceive

        void aroundReceive​(scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receive,
                   java.lang.Object msg)
        Deprecated.
        INTERNAL API
        Specified by:
        aroundReceive in interface Actor
        Parameters:
        receive - (undocumented)
        msg - (undocumented)

      • cancelSelf

        void cancelSelf()
        Deprecated.

      • aroundPreStart

        void aroundPreStart()
        Deprecated.
        INTERNAL API
        Specified by:
        aroundPreStart in interface Actor

      • aroundPreRestart

        void aroundPreRestart​(java.lang.Throwable reason,
                      scala.Option<java.lang.Object> message)
        Deprecated.
        INTERNAL API
        Specified by:
        aroundPreRestart in interface Actor
        Parameters:
        reason - (undocumented)
        message - (undocumented)

      • aroundPostRestart

        void aroundPostRestart​(java.lang.Throwable reason)
        Deprecated.
        INTERNAL API
        Specified by:
        aroundPostRestart in interface Actor
        Parameters:
        reason - (undocumented)

      • aroundPostStop

        void aroundPostStop()
        Deprecated.
        INTERNAL API
        Specified by:
        aroundPostStop in interface Actor