final case class Update[A <: ReplicatedData] extends Command with NoSerializationVerificationNeeded with Product with Serializable
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.
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.
- Source
- Replicator.scala
- Alphabetic
- By Inheritance
- Update
- Serializable
- Serializable
- Product
- Equals
- NoSerializationVerificationNeeded
- Command
- Command
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Instance Constructors
-
new
Update(key: Key[A], initial: A, writeConsistency: WriteConsistency, replyTo: ActorRef[UpdateResponse[A]], request: Optional[Any], modify: Function[A, A])
Modify value of local
Replicator
and replicate with givenwriteConsistency
.Modify value of local
Replicator
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.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 useask
or local correlation data structures. -
new
Update(key: Key[A], initial: A, writeConsistency: WriteConsistency, replyTo: ActorRef[UpdateResponse[A]], modify: Function[A, A])
Modify value of local
Replicator
and replicate with givenwriteConsistency
.Modify value of local
Replicator
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.
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
- def +(other: String): String
- def ->[B](y: B): (Update[A], B)
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate() @throws( ... )
- def ensuring(cond: (Update[A]) ⇒ Boolean, msg: ⇒ Any): Update[A]
- def ensuring(cond: (Update[A]) ⇒ Boolean): Update[A]
- def ensuring(cond: Boolean, msg: ⇒ Any): Update[A]
- def ensuring(cond: Boolean): Update[A]
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def formatted(fmtstr: String): String
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- val key: Key[A]
- val modify: (Option[A]) ⇒ A
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- val replyTo: ActorRef[UpdateResponse[A]]
- val request: Optional[Any]
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
- val writeConsistency: WriteConsistency
- def →[B](y: B): (Update[A], B)