final case class Update(await: Boolean = false, replayMax: Long = Long.MaxValue) extends Product with Serializable
Instructs a PersistentView to update itself. This will run a single incremental message replay with
all messages from the corresponding persistent id's journal that have not yet been consumed by the view.
To update a view with messages that have been written after handling this request, another Update
request must be sent to the view.
- await
if
true, processing of further messages sent to the view will be delayed until the incremental message replay, triggered by this update request, completes. Iffalse, any message sent to the view may interleave with replayed persistent event stream.- replayMax
maximum number of messages to replay when handling this update request. Defaults to
Long.MaxValue(i.e. no limit).
- Annotations
- @SerialVersionUID()
- Source
- PersistentView.scala
- Alphabetic
- By Inheritance
- Update
- Serializable
- Serializable
- Product
- Equals
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Instance Constructors
-
new
Update(await: Boolean = false, replayMax: Long = Long.MaxValue)
- await
if
true, processing of further messages sent to the view will be delayed until the incremental message replay, triggered by this update request, completes. Iffalse, any message sent to the view may interleave with replayed persistent event stream.- replayMax
maximum number of messages to replay when handling this update request. Defaults to
Long.MaxValue(i.e. no limit).
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, B)
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
- val await: Boolean
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
- def ensuring(cond: (Update) ⇒ Boolean, msg: ⇒ Any): Update
- def ensuring(cond: (Update) ⇒ Boolean): Update
- def ensuring(cond: Boolean, msg: ⇒ Any): Update
- def ensuring(cond: Boolean): Update
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
- def formatted(fmtstr: String): String
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- val replayMax: Long
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
- def →[B](y: B): (Update, B)