public class ActorProcessor<I,O> extends ActorPublisher<O> implements org.reactivestreams.Processor<I,O>
ActorPublisher.NormalShutdownException
Constructor and Description |
---|
ActorProcessor(ActorRef impl) |
Modifier and Type | Method and Description |
---|---|
static <I,O> ActorProcessor<I,O> |
apply(ActorRef impl) |
static ActorRef |
impl() |
void |
onComplete() |
void |
onError(java.lang.Throwable t) |
void |
onNext(I elem) |
void |
onSubscribe(org.reactivestreams.Subscription s) |
static void |
shutdown(scala.Option<java.lang.Throwable> reason) |
static void |
subscribe(org.reactivestreams.Subscriber<? super T> subscriber) |
static scala.collection.immutable.Seq<org.reactivestreams.Subscriber<? super T>> |
takePendingSubscribers() |
protected static java.lang.Object |
wakeUpMsg() |
impl, NormalShutdownReason, NormalShutdownReasonMessage, shutdown, SomeNormalShutdownReason, subscribe, takePendingSubscribers, wakeUpMsg
public ActorProcessor(ActorRef impl)
public static <I,O> ActorProcessor<I,O> apply(ActorRef impl)
public static ActorRef impl()
protected static java.lang.Object wakeUpMsg()
public static void subscribe(org.reactivestreams.Subscriber<? super T> subscriber)
public static scala.collection.immutable.Seq<org.reactivestreams.Subscriber<? super T>> takePendingSubscribers()
public static void shutdown(scala.Option<java.lang.Throwable> reason)
public void onSubscribe(org.reactivestreams.Subscription s)
onSubscribe
in interface org.reactivestreams.Subscriber<I>
public void onError(java.lang.Throwable t)
onError
in interface org.reactivestreams.Subscriber<I>
public void onComplete()
onComplete
in interface org.reactivestreams.Subscriber<I>