Package akka.persistence.typed.internal
Class Unhandled$
- java.lang.Object
-
- akka.persistence.typed.javadsl.EffectBuilder<Event,State>
-
- akka.persistence.typed.internal.Unhandled$
-
- 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 Unhandled$ 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 Unhandled$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description Unhandled$()
-
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()
WhenEventSourcedBehaviorWithEnforcedReplies
is used there will be compilation errors if the returned effect isn't aReplyEffect
.<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 actorakka.persistence.typed.internal.EffectImpl<Event,State>
thenUnstashAll()
Unstash the commands that were stashed withEffectFactories.stash
.java.lang.String
toString()
-
Methods inherited from class akka.persistence.typed.javadsl.EffectBuilder
thenReply, thenRun, thenRun
-
-
-
-
Field Detail
-
MODULE$
public static final Unhandled$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
productPrefix
public java.lang.String productPrefix()
- Specified by:
productPrefix
in interfacescala.Product
-
productArity
public int productArity()
- Specified by:
productArity
in interfacescala.Product
-
productElement
public java.lang.Object productElement(int x$1)
- Specified by:
productElement
in interfacescala.Product
-
productIterator
public scala.collection.Iterator<java.lang.Object> productIterator()
- Specified by:
productIterator
in interfacescala.Product
-
canEqual
public boolean canEqual(java.lang.Object x$1)
- Specified by:
canEqual
in interfacescala.Equals
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
events
public scala.collection.immutable.Seq<Event> events()
- Specified by:
events
in interfaceEffectBuilder<Event,State>
-
thenNoReply
public akka.persistence.typed.internal.EffectImpl<Event,State> thenNoReply()
Description copied from class:EffectBuilder
WhenEventSourcedBehaviorWithEnforcedReplies
is used there will be compilation errors if the returned effect isn't aReplyEffect
. ThisthenNoReply
can be used as a conscious decision that a reply shouldn't be sent for a specific command or the reply will be sent later.- Specified by:
thenNoReply
in interfaceEffectBuilder<Event,State>
- Specified by:
thenNoReply
in classEffectBuilder<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 replyToActorRef
.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 withEventSourcedBehavior.withEnforcedReplies
. WhenwithEnforcedReplies
is used there will be compilation errors if the returned effect isn't aReplyEffect
. The reply message will be sent also ifwithEnforcedReplies
isn't used, but then the compiler will not help finding mistakes.- Specified by:
thenReply
in interfaceEffectBuilder<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 interfaceEffectBuilder<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 interfaceEffectBuilder<Event,State>
- Specified by:
thenStop
in interfaceReplyEffect<Event,State>
- Specified by:
thenStop
in interfaceReplyEffect<Event,State>
- Specified by:
thenStop
in classEffectBuilder<Event,State>
-
thenUnstashAll
public akka.persistence.typed.internal.EffectImpl<Event,State> thenUnstashAll()
Description copied from class:EffectBuilder
Unstash the commands that were stashed withEffectFactories.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 anotherunstashAll
.- Specified by:
thenUnstashAll
in interfaceEffectBuilder<Event,State>
- Specified by:
thenUnstashAll
in interfaceReplyEffect<Event,State>
- Specified by:
thenUnstashAll
in interfaceReplyEffect<Event,State>
- Specified by:
thenUnstashAll
in classEffectBuilder<Event,State>
-
-