Package org.apache.pekko.cluster.ddata.typed.scaladsl

Class Replicator.Update$

java.lang.Object

org.apache.pekko.cluster.ddata.typed.scaladsl.Replicator.Update$

All Implemented Interfaces:

Serializable

Enclosing class:

Replicator

public static class Replicator.Update$
extends Object
implements Serializable

See Also:

• Serialized Form

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
Update$()

Method Summary

Modifier and Type	Method	Description
<A extends ReplicatedData> Replicator.Update<A>	apply(Key<A> key, A initial, Replicator.WriteConsistency writeConsistency, ActorRef<Replicator.UpdateResponse<A>> replyTo, scala.Function1<A,A> modify)	Modify value of local Replicator and replicate with given writeConsistency.
<A extends ReplicatedData> scala.Function1<ActorRef<Replicator.UpdateResponse<A>>,Replicator.Update<A>>	apply(Key<A> key, A initial, Replicator.WriteConsistency writeConsistency, scala.Function1<A,A> modify)	Convenience for ask.
<A extends ReplicatedData> Replicator.Update<A>	apply(Key<A> key, Replicator.WriteConsistency writeConsistency, ActorRef<Replicator.UpdateResponse<A>> replyTo, scala.Function1<scala.Option<A>,A> modify)	Send this message to the local Replicator to update a data value for the given key.
<A extends ReplicatedData> scala.Option<scala.Tuple3<Key<A>,Replicator.WriteConsistency,ActorRef<Replicator.UpdateResponse<A>>>>	unapply(Replicator.Update<A> x$0)

Methods inherited from class java.lang.Object

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

Field Details

MODULE$

public static final Replicator.Update$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

Update$

public Update$()

Method Details

apply

public <A extends ReplicatedData>
Replicator.Update<A> apply(Key<A> key,
 A initial,
 Replicator.WriteConsistency writeConsistency,
 ActorRef<Replicator.UpdateResponse<A>> replyTo,
 scala.Function1<A,A> modify)

Modify value of local Replicator and replicate with given writeConsistency.

The current value for the key is passed to the modify function. If there is no current data value for the key the initial value will be passed to the modify function.

apply

public <A extends ReplicatedData>
scala.Function1<ActorRef<Replicator.UpdateResponse<A>>,Replicator.Update<A>> apply(Key<A> key,
 A initial,
 Replicator.WriteConsistency writeConsistency,
 scala.Function1<A,A> modify)

Convenience for ask.

apply

public <A extends ReplicatedData>
Replicator.Update<A> apply(Key<A> key,
 Replicator.WriteConsistency writeConsistency,
 ActorRef<Replicator.UpdateResponse<A>> replyTo,
 scala.Function1<scala.Option<A>,A> modify)

Send this message to the local Replicator to update a data value for the given key. The Replicator will reply with one of the UpdateResponse messages.

Note that the companion object provides apply functions for convenient construction of this message.

The current data value for the key is passed as parameter to the modify function. It is None if there is no value for the key, and otherwise Some(data). The function is supposed to return the new value of the data, which will then be replicated according to the given writeConsistency.

The modify function is called by the Replicator actor and must therefore be a pure function that only uses the data parameter and stable fields from enclosing scope. It must for example not access sender() reference of an enclosing actor.

unapply

public <A extends ReplicatedData>
scala.Option<scala.Tuple3<Key<A>,Replicator.WriteConsistency,ActorRef<Replicator.UpdateResponse<A>>>> unapply(Replicator.Update<A> x$0)