Class 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 Detail

      • MODULE$

        public static final Replicator.Update$ MODULE$
        Static reference to the singleton instance of this Scala object.
    • Constructor Detail

      • Update$

        public Update$()
    • Method Detail

      • apply

        public <A extends ReplicatedDataReplicator.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 Replicator.UpdateResponse messages.

        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.