akka.cluster.ddata

Class Replicator.Update<A extends ReplicatedData>

java.lang.Object

akka.cluster.ddata.Replicator.Update<A>

All Implemented Interfaces:

NoSerializationVerificationNeeded, Replicator.Command<A>, java.io.Serializable, scala.Equals, scala.Product

Enclosing class:

Replicator

public static final class Replicator.Update<A extends ReplicatedData>
extends java.lang.Object
implements Replicator.Command<A>, NoSerializationVerificationNeeded, scala.Product, scala.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Update(Key<A> key, A initial, Replicator.WriteConsistency writeConsistency, java.util.function.Function<A,A> modify) Java API: Modify value of local Replicator and replicate with given writeConsistency.
Update(Key<A> key, A initial, Replicator.WriteConsistency writeConsistency, java.util.Optional<java.lang.Object> request, java.util.function.Function<A,A> modify) Java API: Modify value of local Replicator and replicate with given writeConsistency.
Update(Key<A> key, Replicator.WriteConsistency writeConsistency, scala.Option<java.lang.Object> request, scala.Function1<scala.Option<A>,A> modify)

Method Summary

Modifier and Type	Method and Description
Key<A>	key()
scala.Function1<scala.Option<A>,A>	modify()
scala.Option<java.lang.Object>	request()
Replicator.WriteConsistency	writeConsistency()

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Product

$init$, productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

Update

public Update(Key<A> key,
              Replicator.WriteConsistency writeConsistency,
              scala.Option<java.lang.Object> request,
              scala.Function1<scala.Option<A>,A> modify)

Update

public Update(Key<A> key,
              A initial,
              Replicator.WriteConsistency writeConsistency,
              java.util.function.Function<A,A> modify)

Java API: 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.

Parameters:

key - (undocumented)

initial - (undocumented)

writeConsistency - (undocumented)

modify - (undocumented)

Update

public Update(Key<A> key,
              A initial,
              Replicator.WriteConsistency writeConsistency,
              java.util.Optional<java.lang.Object> request,
              java.util.function.Function<A,A> modify)

Java API: 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.

The optional request context is included in the reply messages. This is a convenient way to pass contextual information (e.g. original sender) without having to use ask or local correlation data structures.

Parameters:

key - (undocumented)

initial - (undocumented)

writeConsistency - (undocumented)

request - (undocumented)

modify - (undocumented)

Method Detail

key

public Key<A> key()

Specified by:

key in interface Replicator.Command<A extends ReplicatedData>

writeConsistency

public Replicator.WriteConsistency writeConsistency()

request

public scala.Option<java.lang.Object> request()

modify

public scala.Function1<scala.Option<A>,A> modify()