Package akka.stream.impl
Class ActorPublisher<T>
- java.lang.Object
-
- akka.stream.impl.ActorPublisher<T>
-
- All Implemented Interfaces:
org.reactivestreams.Publisher<T>
- Direct Known Subclasses:
ActorProcessor
public class ActorPublisher<T> extends java.lang.Object implements org.reactivestreams.Publisher<T>
INTERNAL APIWhen you instantiate this class, or its subclasses, you MUST send an ExposedPublisher message to the wrapped ActorRef! If you don't need to subclass, prefer the apply() method on the companion object which takes care of this.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
ActorPublisher.NormalShutdownException
-
Constructor Summary
Constructors Constructor Description ActorPublisher(ActorRef impl)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static <T> ActorPublisher<T>
apply(ActorRef impl)
ActorRef
impl()
static java.lang.Throwable
NormalShutdownReason()
static java.lang.String
NormalShutdownReasonMessage()
void
shutdown(scala.Option<java.lang.Throwable> reason)
static scala.Some<java.lang.Throwable>
SomeNormalShutdownReason()
void
subscribe(org.reactivestreams.Subscriber<? super T> subscriber)
scala.collection.immutable.Seq<org.reactivestreams.Subscriber<? super T>>
takePendingSubscribers()
protected java.lang.Object
wakeUpMsg()
-
-
-
Constructor Detail
-
ActorPublisher
public ActorPublisher(ActorRef impl)
-
-
Method Detail
-
NormalShutdownReasonMessage
public static java.lang.String NormalShutdownReasonMessage()
-
NormalShutdownReason
public static java.lang.Throwable NormalShutdownReason()
-
SomeNormalShutdownReason
public static scala.Some<java.lang.Throwable> SomeNormalShutdownReason()
-
apply
public static <T> ActorPublisher<T> apply(ActorRef impl)
-
impl
public ActorRef impl()
-
wakeUpMsg
protected java.lang.Object wakeUpMsg()
-
subscribe
public void subscribe(org.reactivestreams.Subscriber<? super T> subscriber)
- Specified by:
subscribe
in interfaceorg.reactivestreams.Publisher<T>
-
takePendingSubscribers
public scala.collection.immutable.Seq<org.reactivestreams.Subscriber<? super T>> takePendingSubscribers()
-
shutdown
public void shutdown(scala.Option<java.lang.Throwable> reason)
-
-