raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Allow Java API to create actor publishers with stash

Browse source
This commit is contained in:
Jan Ypma 2016-06-09 12:41:36 +02:00
parent b95b60a6a5
commit bf746431e0
1 changed files with 21 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

21
akka-stream/src/main/scala/akka/stream/actor/ActorPublisher.scala
View file

@ -469,3 +469,24 @@ object AbstractActorPublisher {
* @see [[akka.stream.actor.ActorPublisher]]
*/
abstract class AbstractActorPublisher[T] extends AbstractActor with ActorPublisher[T]
/**
* Java API compatible with lambda expressions.
* This class adds a Stash to {@link AbstractActorPublisher}.
* @see [[akka.stream.actor.ActorPublisher]] and [[akka.stream.actor.AbstractActorWithStash]]
*/
abstract class AbstractActorPublisherWithStash[T] extends AbstractActor with ActorPublisher[T] with Stash
/**
* Java API compatible with lambda expressions.
* This class adds an unbounded Stash to {@link AbstractActorPublisher}.
* @see [[akka.stream.actor.ActorPublisher]] and [[akka.stream.actor.AbstractActorWithUnboundedStash]]
*/
abstract class AbstractActorPublisherWithUnboundedStash[T] extends AbstractActor with ActorPublisher[T] with UnboundedStash
/**
* Java API compatible with lambda expressions.
* This class adds an unrestricted Stash to {@link AbstractActorPublisher}.
* @see [[akka.stream.actor.ActorPublisher]] and [[akka.stream.actor.AbstractActorWithUnrestrictedStash]]
*/
abstract class AbstractActorPublisherWithUnrestrictedStash[T] extends AbstractActor with ActorPublisher[T] with UnrestrictedStash