From bf746431e03fbc631a935d063c5818ca1beff7eb Mon Sep 17 00:00:00 2001 From: Jan Ypma Date: Thu, 9 Jun 2016 12:41:36 +0200 Subject: [PATCH] Allow Java API to create actor publishers with stash --- .../akka/stream/actor/ActorPublisher.scala | 21 +++++++++++++++++++ 1 file changed, 21 insertions(+) diff --git a/akka-stream/src/main/scala/akka/stream/actor/ActorPublisher.scala b/akka-stream/src/main/scala/akka/stream/actor/ActorPublisher.scala index ee930b4b24..1ba9acdf90 100644 --- a/akka-stream/src/main/scala/akka/stream/actor/ActorPublisher.scala +++ b/akka-stream/src/main/scala/akka/stream/actor/ActorPublisher.scala @@ -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