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 API

When 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

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 interface org.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)