Package org.apache.pekko.persistence.typed.internal

Class Unhandled$

java.lang.Object
org.apache.pekko.persistence.typed.javadsl.EffectBuilder<Event,State>
org.apache.pekko.persistence.typed.internal.Unhandled$
All Implemented Interfaces:
Serializable, 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$>, scala.Equals, scala.Product
public class Unhandled$ extends EffectBuilder<Event,State> implements scala.Product, Serializable
INTERNAL API
See Also:

  • Field Summary

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

  • Constructor Summary

    Constructors
    Constructor
    Description
    Unhandled$()
     

  • Method Summary

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

    Methods inherited from class org.apache.pekko.persistence.typed.javadsl.EffectBuilder

    thenReply, thenRun, thenRun

    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 Details

    • MODULE$

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

  • Constructor Details

    • Unhandled$

      public Unhandled$()

  • Method Details

    • productPrefix

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

    • productArity

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

    • productElement

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

    • productIterator

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

    • canEqual

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

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • events

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

    • thenNoReply

      public org.apache.pekko.persistence.typed.internal.EffectImpl<scala.runtime.Nothing$,scala.runtime.Nothing$> thenNoReply()
      Description copied from class: EffectBuilder
      When EventSourcedBehaviorWithEnforcedReplies is used there will be compilation errors if the returned effect isn't a ReplyEffect. This thenNoReply 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 interface EffectBuilder<Event,State>
      Specified by:
      thenNoReply in class EffectBuilder<Event,State>

    • thenReply

      public <ReplyMessage> org.apache.pekko.persistence.typed.internal.EffectImpl<scala.runtime.Nothing$,scala.runtime.Nothing$> thenReply(ActorRef<ReplyMessage> replyTo, scala.Function1<scala.runtime.Nothing$,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 org.apache.pekko.persistence.typed.internal.EffectImpl<scala.runtime.Nothing$,scala.runtime.Nothing$> thenRun(scala.Function1<scala.runtime.Nothing$,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 org.apache.pekko.persistence.typed.internal.EffectImpl<scala.runtime.Nothing$,scala.runtime.Nothing$> 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 org.apache.pekko.persistence.typed.internal.EffectImpl<scala.runtime.Nothing$,scala.runtime.Nothing$> 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>