Package akka.persistence.typed.internal

Class Stash$

  • All Implemented Interfaces:
    Effect<scala.runtime.Nothing$,​scala.runtime.Nothing$>, ReplyEffect<scala.runtime.Nothing$,​scala.runtime.Nothing$>, Effect<scala.runtime.Nothing$,​scala.runtime.Nothing$>, EffectBuilder<scala.runtime.Nothing$,​scala.runtime.Nothing$>, ReplyEffect<scala.runtime.Nothing$,​scala.runtime.Nothing$>, java.io.Serializable, scala.Equals, scala.Product
    public class Stash$
extends EffectBuilder<Event,​State>
implements scala.Product, java.io.Serializable
    INTERNAL API
    See Also:
    Serialized Form

    • Field Summary

      Fields 
      Modifier and Type Field Description
      static Stash$ MODULE$
      Static reference to the singleton instance of this Scala object.

    • Constructor Summary

      Constructors 
      Constructor Description
      Stash$()  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      boolean canEqual​(java.lang.Object x$1)  
      scala.collection.immutable.Seq<Event> events()  
      int hashCode()  
      int productArity()  
      java.lang.Object productElement​(int x$1)  
      scala.collection.Iterator<java.lang.Object> productIterator()  
      java.lang.String productPrefix()  
      akka.persistence.typed.internal.EffectImpl<Event,​State> thenNoReply()
      When EventSourcedBehaviorWithEnforcedReplies is used there will be compilation errors if the returned effect isn't a ReplyEffect.
      <ReplyMessage>
      akka.persistence.typed.internal.EffectImpl<Event,​State>      		 thenReply​(ActorRef<ReplyMessage> replyTo, scala.Function1<State,​ReplyMessage> replyWithMessage)
      Send a reply message to the command.
      akka.persistence.typed.internal.EffectImpl<Event,​State> thenRun​(scala.Function1<State,​scala.runtime.BoxedUnit> chainedEffect)
      Run the given callback.
      akka.persistence.typed.internal.EffectImpl<Event,​State> thenStop()
      The side effect is to stop the actor
      akka.persistence.typed.internal.EffectImpl<Event,​State> thenUnstashAll()
      Unstash the commands that were stashed with EffectFactories.stash.
      java.lang.String toString()  

      • Methods inherited from class java.lang.Object

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

      • Methods inherited from interface scala.Equals

        equals

      • Methods inherited from interface scala.Product

        productElementName, productElementNames

    • Field Detail

      • MODULE$

        public static final Stash$ MODULE$
        Static reference to the singleton instance of this Scala object.

    • Constructor Detail

      • Stash$

        public Stash$()

    • Method Detail

      • productPrefix

        public java.lang.String productPrefix()
        Specified by:
        productPrefix in interface scala.Product

      • productArity

        public int productArity()
        Specified by:
        productArity in interface scala.Product

      • productElement

        public java.lang.Object productElement​(int x$1)
        Specified by:
        productElement in interface scala.Product

      • productIterator

        public scala.collection.Iterator<java.lang.Object> productIterator()
        Specified by:
        productIterator in interface scala.Product

      • canEqual

        public boolean canEqual​(java.lang.Object x$1)
        Specified by:
        canEqual in interface scala.Equals

      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object

      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object

      • events

        public scala.collection.immutable.Seq<Event> events()
        Specified by:
        events in interface EffectBuilder<Event,​State>

      • thenReply

        public <ReplyMessage> akka.persistence.typed.internal.EffectImpl<Event,​State> thenReply​(ActorRef<ReplyMessage> replyTo,
                                                                                              scala.Function1<State,​ReplyMessage> replyWithMessage)
        Description copied from interface: EffectBuilder
        Send a reply message to the command. The type of the reply message must conform to the type specified by the passed replyTo ActorRef.

        This has the same semantics as replyTo.tell.

        It is provided as a convenience (reducing boilerplate) and a way to enforce that replies are not forgotten when the EventSourcedBehavior is created with EventSourcedBehavior.withEnforcedReplies. When withEnforcedReplies is used there will be compilation errors if the returned effect isn't a ReplyEffect. The reply message will be sent also if withEnforcedReplies isn't used, but then the compiler will not help finding mistakes.

        Specified by:
        thenReply in interface EffectBuilder<Event,​State>

      • thenRun

        public akka.persistence.typed.internal.EffectImpl<Event,​State> thenRun​(scala.Function1<State,​scala.runtime.BoxedUnit> chainedEffect)
        Description copied from interface: EffectBuilder
        Run the given callback. Callbacks are run sequentially.
        Specified by:
        thenRun in interface EffectBuilder<Event,​State>

      • thenStop

        public akka.persistence.typed.internal.EffectImpl<Event,​State> thenStop()
        Description copied from class: EffectBuilder
        The side effect is to stop the actor
        Specified by:
        thenStop in interface EffectBuilder<Event,​State>
        Specified by:
        thenStop in class EffectBuilder<Event,​State>

      • thenUnstashAll

        public akka.persistence.typed.internal.EffectImpl<Event,​State> thenUnstashAll()
        Description copied from class: EffectBuilder
        Unstash the commands that were stashed with EffectFactories.stash.

        It's allowed to stash messages while unstashing. Those newly added commands will not be processed by this unstashAll effect and have to be unstashed by another unstashAll.

        Specified by:
        thenUnstashAll in interface EffectBuilder<Event,​State>
        Specified by:
        thenUnstashAll in interface ReplyEffect<Event,​State>
        Specified by:
        thenUnstashAll in interface ReplyEffect<Event,​State>
        Specified by:
        thenUnstashAll in class EffectBuilder<Event,​State>