trait FullMVState[V, T <: (FullMVBundle.this)#FullMVTurn, Reactive, OutDep] extends AnyRef
- Alphabetic
- By Inheritance
- FullMVState
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def discover(txn: T, add: OutDep): (List[T], Option[T])
entry point for discover(this, add).
entry point for discover(this, add). May suspend.
- txn
the executing reevaluation's transaction
- add
the new edge's sink node
- returns
the appropriate Version.value.
- abstract def drop(txn: T, remove: OutDep): (List[T], Option[T])
entry point for drop(this, ticket.issuer); may suspend temporarily.
entry point for drop(this, ticket.issuer); may suspend temporarily.
- txn
the executing reevaluation's transaction
- remove
the removed edge's sink node
- abstract def dynamicAfter(txn: T): V
entry point for after(this); may suspend.
entry point for after(this); may suspend.
- txn
the executing transaction
- returns
the corresponding
Version.valuefrom after this transaction, i.e., awaiting and returning the transaction's own write if one has occurred or will occur.
- abstract def dynamicBefore(txn: T): V
entry point for before(this); may suspend.
entry point for before(this); may suspend.
- txn
the executing transaction
- returns
the corresponding
Version.valuefrom before this transaction, i.e., ignoring the transaction's own writes.
- abstract val host: (FullMVBundle.this)#FullMVEngine
- abstract def incrementFrame(txn: T): FramingBranchResult[T, OutDep]
entry point for regular framing
entry point for regular framing
- txn
the transaction visiting the node for framing
- abstract def incrementSupersedeFrame(txn: T, supersede: T): FramingBranchResult[T, OutDep]
entry point for superseding framing
entry point for superseding framing
- txn
the transaction visiting the node for framing
- supersede
the transaction whose frame was superseded by the visiting transaction at the previous node
- abstract def latestValue: V
- abstract def notify(txn: T, changed: Boolean): (Boolean, NotificationBranchResult[T, OutDep])
entry point for change/nochange notification reception
entry point for change/nochange notification reception
- txn
the transaction sending the notification
- changed
whether or not the dependency changed
- abstract def notifyFollowFrame(txn: T, changed: Boolean, followFrame: T): (Boolean, NotificationBranchResult[T, OutDep])
entry point for change/nochange notification reception with follow-up framing
entry point for change/nochange notification reception with follow-up framing
- txn
the transaction sending the notification
- changed
whether or not the dependency changed
- followFrame
a transaction for which to create a subsequent frame, furthering its partial framing.
- abstract def reevIn(turn: T): V
- abstract def reevOut(turn: T, maybeValue: Option[V], unchange: (V) => V): ReevOutBranchResult[T, OutDep]
progress
firstFrameforward until aVersion.isFrameis encountered, and return the resulting notification out (with reframing if subsequent write is found). - abstract def retrofitSinkFrames(successorWrittenVersions: Seq[T], maybeSuccessorFrame: Option[T], arity: Int): Seq[T]
performs the reframings on the sink of a discover(n, this) with arity +1, or drop(n, this) with arity -1
performs the reframings on the sink of a discover(n, this) with arity +1, or drop(n, this) with arity -1
- successorWrittenVersions
the reframings to perform for successor written versions
- maybeSuccessorFrame
maybe a reframing to perform for the first successor frame
- arity
+1 for discover adding frames, -1 for drop removing frames.
- abstract def staticAfter(txn: T): V
- abstract def staticBefore(txn: T): V
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- val incomings: Set[Reactive]
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])