Class Replicator.Update$
- java.lang.Object
-
- akka.cluster.ddata.typed.scaladsl.Replicator.Update$
-
- All Implemented Interfaces:
java.io.Serializable
- Enclosing class:
- Replicator
public static class Replicator.Update$ extends java.lang.Object implements java.io.Serializable
- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description static Replicator.Update$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description Update$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <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 localReplicator
to update a data value for the givenkey
.<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 localReplicator
and replicate with givenwriteConsistency
.<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 forask
.<A extends ReplicatedData>
scala.Option<scala.Tuple3<Key<A>,Replicator.WriteConsistency,ActorRef<Replicator.UpdateResponse<A>>>>unapply(Replicator.Update<A> x$0)
-
-
-
Field Detail
-
MODULE$
public static final Replicator.Update$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
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 localReplicator
and replicate with givenwriteConsistency
.The current value for the
key
is passed to themodify
function. If there is no current data value for thekey
theinitial
value will be passed to themodify
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 forask
.
-
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 localReplicator
to update a data value for the givenkey
. TheReplicator
will reply with one of theUpdateResponse
messages.Note that the
companion
object providesapply
functions for convenient construction of this message.The current data value for the
key
is passed as parameter to themodify
function. It isNone
if there is no value for thekey
, and otherwiseSome(data)
. The function is supposed to return the new value of the data, which will then be replicated according to the givenwriteConsistency
.The
modify
function is called by theReplicator
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 accesssender()
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)
-
-