Class InputStreamPublisher

    • Constructor Detail

      • InputStreamPublisher

        public InputStreamPublisher​(java.io.InputStream is,
                                    scala.concurrent.Promise<IOResult> completionPromise,
                                    int chunkSize)
    • Method Detail

      • props

        public static Props props​(java.io.InputStream is,
                                  scala.concurrent.Promise<IOResult> completionPromise,
                                  int chunkSize)
      • sender

        public static final ActorRef sender()
      • preStart

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

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

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

        public static void unhandled​(java.lang.Object message)
      • akka$stream$actor$ActorPublisher$$state

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

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

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

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

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

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

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

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

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

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

        public static final boolean isActive()
      • totalDemand

        public static final long totalDemand()
      • isCompleted

        public static final boolean isCompleted()
      • isErrorEmitted

        public static final boolean isErrorEmitted()
      • isCanceled

        public static final boolean isCanceled()
      • onNext

        public static void onNext​(T element)
      • onComplete

        public static void onComplete()
      • onCompleteThenStop

        public static void onCompleteThenStop()
      • onError

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

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

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

        protected static void aroundPreStart()
      • aroundPreRestart

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

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

        protected static void aroundPostStop()
      • 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)
      • akka$actor$ActorLogging$$_log

        public static LoggingAdapter akka$actor$ActorLogging$$_log()
      • akka$actor$ActorLogging$$_log_$eq

        public static void akka$actor$ActorLogging$$_log_$eq​(LoggingAdapter x$1)
      • context

        public ActorContext context()
        Description copied from interface: Actor
        Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such as forward.

        WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

        ActorContext is the Scala API. getContext returns a AbstractActor.ActorContext, which is the Java API of the actor context.

        Specified by:
        context in interface Actor
        Returns:
        (undocumented)
      • self

        public final ActorRef self()
        Description copied from interface: Actor
        The 'self' field holds the ActorRef for this actor.

        Can be used to send messages to itself:
         self ! message
         
        Specified by:
        self in interface Actor
        Returns:
        (undocumented)
      • akka$actor$Actor$_setter_$context_$eq

        protected void akka$actor$Actor$_setter_$context_$eq​(ActorContext x$1)
        Description copied from interface: Actor
        Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such as forward.

        WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

        ActorContext is the Scala API. getContext returns a AbstractActor.ActorContext, which is the Java API of the actor context.

        Specified by:
        akka$actor$Actor$_setter_$context_$eq in interface Actor
        Parameters:
        x$1 - (undocumented)
      • akka$actor$Actor$_setter_$self_$eq

        protected final void akka$actor$Actor$_setter_$self_$eq​(ActorRef x$1)
        Description copied from interface: Actor
        The 'self' field holds the ActorRef for this actor.

        Can be used to send messages to itself:
         self ! message
         
        Specified by:
        akka$actor$Actor$_setter_$self_$eq in interface Actor
        Parameters:
        x$1 - (undocumented)
      • arr

        public byte[] arr()
      • readBytesTotal

        public long readBytesTotal()
      • readBytesTotal_$eq

        public void readBytesTotal_$eq​(long x$1)
      • receive

        public scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receive()
        Description copied from interface: Actor
        Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.
        Specified by:
        receive in interface Actor
        Returns:
        (undocumented)
      • readAndSignal

        public void readAndSignal()
      • readAndEmit

        public void readAndEmit()
      • postStop

        public void postStop()
        Description copied from interface: Actor
        User overridable callback.

        Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.
        Specified by:
        postStop in interface Actor