class MapDeltaSeq[T, A] extends (IncrementalBundle.this)#Base[Delta[A]] with (IncrementalBundle.this)#ReactiveDeltaSeq[A]
Class used for filtering ReactiveDeltaSeq
- T
Value inside Delta
- Alphabetic
- By Inheritance
- MapDeltaSeq
- ReactiveDeltaSeq
- DisconnectableImpl
- Disconnectable
- Derived
- Base
- ReSource
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new MapDeltaSeq(in: (IncrementalBundle.this)#ReactiveDeltaSeq[T], op: (T) => A)(initialState: SeqState[A], name: ReName)
- in
the ReactiveDeltaSeq to filter
- op
mapOperation to map sequence
- initialState
...
- name
Name of the new filtered sequence
Type Members
- final type ReIn = (IncrementalBundle.this)#ReevTicket[Value]
- Definition Classes
- Derived
- final type Rout = (IncrementalBundle.this)#Result[Value]
- Definition Classes
- Derived
- type Value = Delta[A]
the value of deltas send through the set
the value of deltas send through the set
- Definition Classes
- ReactiveDeltaSeq → ReSource
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- def ++(that: (IncrementalBundle.this)#ReactiveDeltaSeq[A])(implicit ticket: (IncrementalBundle.this)#CreationTicket): (IncrementalBundle.this)#ReactiveDeltaSeq[A]
Concatenates the ReactiveDeltaSeq with another (that) ReactiveDeltaSeq by returning a new ReactiveDeltaSeq (ConcatenateDeltaSeq)
Concatenates the ReactiveDeltaSeq with another (that) ReactiveDeltaSeq by returning a new ReactiveDeltaSeq (ConcatenateDeltaSeq)
- that
the ReactiveDeltaSeq which will be concatenated with this
- ticket
used for the creation of the concatenated ReactiveDeltaSeq
- returns
ConcatenateDeltaSeq
- Definition Classes
- ReactiveDeltaSeq
- Annotations
- @cutOutOfUserComputation()
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def asEvent(implicit ticket: (IncrementalBundle.this)#CreationTicket): (IncrementalBundle.this)#Event[Delta[A]]
Returns current ReactiveDeltaSeq as an Event
Returns current ReactiveDeltaSeq as an Event
- ticket
a creation ticket as a new event will be created which has the ReactiveDeltaSeq as dependency
- Definition Classes
- ReactiveDeltaSeq
- Annotations
- @cutOutOfUserComputation()
- 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()
- def commit(base: Delta[A]): Delta[A]
- Attributes
- protected[rescala]
- Definition Classes
- ReactiveDeltaSeq → ReSource
- def contains(element: A)(implicit ticket: (IncrementalBundle.this)#CreationTicket, ord: Ordering[A]): (IncrementalBundle.this)#Signal[Boolean]
To check if an element is in the sequence
To check if an element is in the sequence
- element
element to search for
- ticket
for creating the Signal holding the boolean value
- Definition Classes
- ReactiveDeltaSeq
- Annotations
- @cutOutOfUserComputation()
- def count(fulfillsCondition: (A) => Boolean)(implicit ticket: (IncrementalBundle.this)#CreationTicket): (IncrementalBundle.this)#Signal[Int]
Counts number of elements fulfilling the condition provided
Counts number of elements fulfilling the condition provided
- fulfillsCondition
the condition values of deltas have to fulfill to be taken in consideration
- ticket
for creating the Signal holding the value of counted elements
- Definition Classes
- ReactiveDeltaSeq
- Annotations
- @cutOutOfUserComputation()
- final def disconnect(): Unit
- Definition Classes
- DisconnectableImpl → Disconnectable
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def exists(fulfillsCondition: (A) => Boolean)(implicit ticket: (IncrementalBundle.this)#CreationTicket): (IncrementalBundle.this)#Signal[Boolean]
To check if elements fulfilling the condition exists
To check if elements fulfilling the condition exists
- fulfillsCondition
the condition values of deltas have to fulfill to be taken in consideration
- ticket
for creating the Signal holding the boolean value
- Definition Classes
- ReactiveDeltaSeq
- Annotations
- @cutOutOfUserComputation()
- def filter(filterOperation: (A) => Boolean)(implicit ticket: (IncrementalBundle.this)#CreationTicket): (IncrementalBundle.this)#ReactiveDeltaSeq[A]
Filters the sequence , basing on filterExpression and returns the new filtered sequence
Filters the sequence , basing on filterExpression and returns the new filtered sequence
- filterOperation
the operation used for filtering
- ticket
for creating the new source
- returns
the filtered ReactiveDeltaSeq
- Definition Classes
- ReactiveDeltaSeq
- Annotations
- @cutOutOfUserComputation()
- def foldUndo[A](initial: A)(fold: (A, Delta[A]) => A)(unfold: (A, Delta[A]) => A)(implicit ticket: (IncrementalBundle.this)#CreationTicket): (IncrementalBundle.this)#Signal[A]
Based on the concept of reversible Folds Used to fold the deltas basing on fold for Addition-Delta and unfold for Removal-Delta
Based on the concept of reversible Folds Used to fold the deltas basing on fold for Addition-Delta and unfold for Removal-Delta
- A
the value returned by applying fold or unfold on the value T of Deltas
- initial
is the initial value the foldUndo folds to
- fold
the function used when an Addition occurs
- unfold
the function used when a Removal occurs
- ticket
as we will create
- Definition Classes
- ReactiveDeltaSeq
- Annotations
- @cutOutOfUserComputation()
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- def guardedReevaluate(input: ReIn): Rout
- input
Basing ReIn Ticket maps the ReactiveDeltaSeq using the fold defined above. That it uses withValue to write the new Sequence
- returns
Returns the new Sequence
- Attributes
- protected[rescala]
- Definition Classes
- MapDeltaSeq → DisconnectableImpl
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def map[A](mapOperation: (A) => A)(implicit ticket: (IncrementalBundle.this)#CreationTicket): (IncrementalBundle.this)#ReactiveDeltaSeq[A]
Maps the elements of ReactiveDeltaSeq and returns a new ReactiveDeltaSeq with the mapped deltas with the old ReactiveDeltaSeq as dependency
Maps the elements of ReactiveDeltaSeq and returns a new ReactiveDeltaSeq with the mapped deltas with the old ReactiveDeltaSeq as dependency
- A
new Value type for deltas in the mapped ReactiveDeltaSeq
- mapOperation
the operation used for mapping the values of ReactiveDeltaSeq to MapDeltaSeq
- ticket
Ticket for creating the new ReactiveDeltaSeq
- returns
the mapped ReactiveDeltaSeq
- Definition Classes
- ReactiveDeltaSeq
- Annotations
- @cutOutOfUserComputation()
- def max(implicit ticket: (IncrementalBundle.this)#CreationTicket, ord: Ordering[A]): (IncrementalBundle.this)#Signal[Option[A]]
- ticket
used for creation of new sources
- ord
the ordering needed to compare values of deltas for finding the minimum
- returns
Signal holding the optional minimum (as it could be None if the seqeunce is empty)
- Definition Classes
- ReactiveDeltaSeq
- Annotations
- @cutOutOfUserComputation()
- def min(implicit ticket: (IncrementalBundle.this)#CreationTicket, ord: Ordering[A]): (IncrementalBundle.this)#Signal[Option[A]]
- ticket
used for creation of new sources
- ord
the ordering needed to compare values of deltas for finding the minimum
- returns
Signal holding the optional minimum (as it could be None if the seqeunce is empty)
- Definition Classes
- ReactiveDeltaSeq
- Annotations
- @cutOutOfUserComputation()
- val name: ReName
- 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 reevaluate(rein: ReIn): Rout
called if any of the dependencies (rescala.core.Core.ReSources) changed in the current update turn, after all (known) dependencies are updated
called if any of the dependencies (rescala.core.Core.ReSources) changed in the current update turn, after all (known) dependencies are updated
- Attributes
- protected[rescala]
- Definition Classes
- DisconnectableImpl → Derived
- def size(implicit ticket: (IncrementalBundle.this)#CreationTicket): (IncrementalBundle.this)#Signal[Int]
Returns the sizeOfSeq of the ReactiveDeltaSeq
Returns the sizeOfSeq of the ReactiveDeltaSeq
- ticket
for creating the Signal holding the value of sizeOfSeq
- Definition Classes
- ReactiveDeltaSeq
- Annotations
- @cutOutOfUserComputation()
- val state: (IncrementalBundle.this)#State[Delta[A]]
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- Base → 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])