Package akka.persistence.typed.internal

Class EventSourcedBehaviorImpl$

java.lang.Object

akka.persistence.typed.internal.EventSourcedBehaviorImpl$

All Implemented Interfaces:

java.io.Serializable

public class EventSourcedBehaviorImpl$
extends java.lang.Object
implements java.io.Serializable

See Also:

Serialized Form

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
EventSourcedBehaviorImpl$()

Method Summary

Modifier and Type	Method	Description
<Command,Event,State> SnapshotAdapter<State>	$lessinit$greater$default$10()
<Command,Event,State> <any>	$lessinit$greater$default$11()
<Command,Event,State> Recovery	$lessinit$greater$default$12()
<Command,Event,State> RetentionCriteria	$lessinit$greater$default$13()
<Command,Event,State> SupervisorStrategy	$lessinit$greater$default$14()
<Command,Event,State> scala.PartialFunction<java.lang.Object,scala.runtime.Nothing$>	$lessinit$greater$default$15()
<Command,Event,State> scala.Option<akka.persistence.typed.internal.ReplicationSetup>	$lessinit$greater$default$16()
<Command,Event,State> boolean	$lessinit$greater$default$17()
<Command,Event,State> scala.Option<java.lang.Object>	$lessinit$greater$default$18()
<Command,Event,State> scala.None$	$lessinit$greater$default$19()
<Command,Event,State> scala.Option<java.lang.String>	$lessinit$greater$default$6()	Used to start the replication stream at the correct sequence number
<Command,Event,State> scala.Option<java.lang.String>	$lessinit$greater$default$7()
<Command,Event,State> scala.Function2<State,Event,scala.collection.immutable.Set<java.lang.String>>	$lessinit$greater$default$8()
<Command,Event,State> <any>	$lessinit$greater$default$9()
<Command,Event,State> akka.persistence.typed.internal.EventSourcedBehaviorImpl<Command,Event,State>	apply(PersistenceId persistenceId, State emptyState, scala.Function2<State,Command,Effect<Event,State>> commandHandler, scala.Function2<State,Event,State> eventHandler, java.lang.Class<?> loggerClass, scala.Option<java.lang.String> journalPluginId, scala.Option<java.lang.String> snapshotPluginId, scala.Function2<State,Event,scala.collection.immutable.Set<java.lang.String>> tagger, EventAdapter<Event,java.lang.Object> eventAdapter, SnapshotAdapter<State> snapshotAdapter, <any> snapshotWhen, Recovery recovery, RetentionCriteria retention, SupervisorStrategy supervisionStrategy, scala.PartialFunction<scala.Tuple2<State,Signal>,scala.runtime.BoxedUnit> signalHandler, scala.Option<akka.persistence.typed.internal.ReplicationSetup> replication, boolean publishEvents, scala.Option<java.lang.Object> customStashCapacity, scala.Option<ReplicationInterceptor<State,Event>> replicatedEventInterceptor)
<Command,Event,State> SnapshotAdapter<State>	apply$default$10()
<Command,Event,State> <any>	apply$default$11()
<Command,Event,State> Recovery	apply$default$12()
<Command,Event,State> RetentionCriteria	apply$default$13()
<Command,Event,State> SupervisorStrategy	apply$default$14()
<Command,Event,State> scala.PartialFunction<java.lang.Object,scala.runtime.Nothing$>	apply$default$15()
<Command,Event,State> scala.Option<akka.persistence.typed.internal.ReplicationSetup>	apply$default$16()
<Command,Event,State> boolean	apply$default$17()
<Command,Event,State> scala.Option<java.lang.Object>	apply$default$18()
<Command,Event,State> scala.None$	apply$default$19()
<Command,Event,State> scala.Option<java.lang.String>	apply$default$6()
<Command,Event,State> scala.Option<java.lang.String>	apply$default$7()
<Command,Event,State> scala.Function2<State,Event,scala.collection.immutable.Set<java.lang.String>>	apply$default$8()
<Command,Event,State> <any>	apply$default$9()
<Command,Event,State> scala.Option<scala.Tuple19<PersistenceId,State,scala.Function2<State,Command,Effect<Event,State>>,scala.Function2<State,Event,State>,java.lang.Class<?>,scala.Option<java.lang.String>,scala.Option<java.lang.String>,scala.Function2<State,Event,scala.collection.immutable.Set<java.lang.String>>,EventAdapter<Event,java.lang.Object>,SnapshotAdapter<State>,<any>,Recovery,RetentionCriteria,SupervisorStrategy,scala.PartialFunction<scala.Tuple2<State,Signal>,scala.runtime.BoxedUnit>,scala.Option<akka.persistence.typed.internal.ReplicationSetup>,java.lang.Object,scala.Option<java.lang.Object>,scala.Option<ReplicationInterceptor<State,Event>>>>	unapply(akka.persistence.typed.internal.EventSourcedBehaviorImpl<Command,Event,State> x$0)

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final EventSourcedBehaviorImpl$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

EventSourcedBehaviorImpl$

public EventSourcedBehaviorImpl$()

Method Detail

$lessinit$greater$default$6

public <Command,Event,State> scala.Option<java.lang.String> $lessinit$greater$default$6()

Used to start the replication stream at the correct sequence number

$lessinit$greater$default$7

public <Command,Event,State> scala.Option<java.lang.String> $lessinit$greater$default$7()

$lessinit$greater$default$8

public <Command,Event,State> scala.Function2<State,Event,scala.collection.immutable.Set<java.lang.String>> $lessinit$greater$default$8()

$lessinit$greater$default$9

public <Command,Event,State> <any> $lessinit$greater$default$9()

$lessinit$greater$default$10

public <Command,Event,State> SnapshotAdapter<State> $lessinit$greater$default$10()

$lessinit$greater$default$11

public <Command,Event,State> <any> $lessinit$greater$default$11()

$lessinit$greater$default$12

public <Command,Event,State> Recovery $lessinit$greater$default$12()

$lessinit$greater$default$13

public <Command,Event,State> RetentionCriteria $lessinit$greater$default$13()

$lessinit$greater$default$14

public <Command,Event,State> SupervisorStrategy $lessinit$greater$default$14()

$lessinit$greater$default$15

public <Command,Event,State> scala.PartialFunction<java.lang.Object,scala.runtime.Nothing$> $lessinit$greater$default$15()

$lessinit$greater$default$16

public <Command,Event,State> scala.Option<akka.persistence.typed.internal.ReplicationSetup> $lessinit$greater$default$16()

$lessinit$greater$default$17

public <Command,Event,State> boolean $lessinit$greater$default$17()

$lessinit$greater$default$18

public <Command,Event,State> scala.Option<java.lang.Object> $lessinit$greater$default$18()

$lessinit$greater$default$19

public <Command,Event,State> scala.None$ $lessinit$greater$default$19()

apply

public <Command,Event,State> akka.persistence.typed.internal.EventSourcedBehaviorImpl<Command,Event,State> apply(PersistenceId persistenceId,
                                                                                                                                         State emptyState,
                                                                                                                                         scala.Function2<State,Command,Effect<Event,State>> commandHandler,
                                                                                                                                         scala.Function2<State,Event,State> eventHandler,
                                                                                                                                         java.lang.Class<?> loggerClass,
                                                                                                                                         scala.Option<java.lang.String> journalPluginId,
                                                                                                                                         scala.Option<java.lang.String> snapshotPluginId,
                                                                                                                                         scala.Function2<State,Event,scala.collection.immutable.Set<java.lang.String>> tagger,
                                                                                                                                         EventAdapter<Event,java.lang.Object> eventAdapter,
                                                                                                                                         SnapshotAdapter<State> snapshotAdapter,
                                                                                                                                         <any> snapshotWhen,
                                                                                                                                         Recovery recovery,
                                                                                                                                         RetentionCriteria retention,
                                                                                                                                         SupervisorStrategy supervisionStrategy,
                                                                                                                                         scala.PartialFunction<scala.Tuple2<State,Signal>,scala.runtime.BoxedUnit> signalHandler,
                                                                                                                                         scala.Option<akka.persistence.typed.internal.ReplicationSetup> replication,
                                                                                                                                         boolean publishEvents,
                                                                                                                                         scala.Option<java.lang.Object> customStashCapacity,
                                                                                                                                         scala.Option<ReplicationInterceptor<State,Event>> replicatedEventInterceptor)

apply$default$10

public <Command,Event,State> SnapshotAdapter<State> apply$default$10()

apply$default$11

public <Command,Event,State> <any> apply$default$11()

apply$default$12

public <Command,Event,State> Recovery apply$default$12()

apply$default$13

public <Command,Event,State> RetentionCriteria apply$default$13()

apply$default$14

public <Command,Event,State> SupervisorStrategy apply$default$14()

apply$default$15

public <Command,Event,State> scala.PartialFunction<java.lang.Object,scala.runtime.Nothing$> apply$default$15()

apply$default$16

public <Command,Event,State> scala.Option<akka.persistence.typed.internal.ReplicationSetup> apply$default$16()

apply$default$17

public <Command,Event,State> boolean apply$default$17()

apply$default$18

public <Command,Event,State> scala.Option<java.lang.Object> apply$default$18()

apply$default$19

public <Command,Event,State> scala.None$ apply$default$19()

apply$default$6

public <Command,Event,State> scala.Option<java.lang.String> apply$default$6()

apply$default$7

public <Command,Event,State> scala.Option<java.lang.String> apply$default$7()

apply$default$8

public <Command,Event,State> scala.Function2<State,Event,scala.collection.immutable.Set<java.lang.String>> apply$default$8()

apply$default$9

public <Command,Event,State> <any> apply$default$9()

unapply

public <Command,Event,State> scala.Option<scala.Tuple19<PersistenceId,State,scala.Function2<State,Command,Effect<Event,State>>,scala.Function2<State,Event,State>,java.lang.Class<?>,scala.Option<java.lang.String>,scala.Option<java.lang.String>,scala.Function2<State,Event,scala.collection.immutable.Set<java.lang.String>>,EventAdapter<Event,java.lang.Object>,SnapshotAdapter<State>,<any>,Recovery,RetentionCriteria,SupervisorStrategy,scala.PartialFunction<scala.Tuple2<State,Signal>,scala.runtime.BoxedUnit>,scala.Option<akka.persistence.typed.internal.ReplicationSetup>,java.lang.Object,scala.Option<java.lang.Object>,scala.Option<ReplicationInterceptor<State,Event>>>> unapply(akka.persistence.typed.internal.EventSourcedBehaviorImpl<Command,Event,State> x$0)