abstract class AbstractEvent[T] extends Event[T]
Abstract Event class for Java compatibility.
- Alphabetic
- By Inheritance
- AbstractEvent
- Event
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new AbstractEvent()
Abstract Value Members
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 build[U >: T, That <: Seq[U]](implicit factory: Factory[U, That]): Event[That]
Progressively build a Seq of events using the passed-in builder.
Progressively build a Seq of events using the passed-in builder. A value containing the current version of the collection is notified for each incoming event.
- Definition Classes
- Event
- def buildAny[That](implicit factory: Factory[T, That]): Event[That]
Progressively build any collection of events using the passed-in builder.
Progressively build any collection of events using the passed-in builder. A value containing the current version of the collection is notified for each incoming event.
- Definition Classes
- Event
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def collect[U](f: PartialFunction[T, U]): Event[U]
Build a new Event by applying the given function to each value observed.
Build a new Event by applying the given function to each value observed. Event values for which the partial function
fdoes not apply are dropped; other values are transformed byf.- Definition Classes
- Event
- def dedup: Event[T]
Builds a new Event by keeping only the Events where the previous and current values are not
==to each other.Builds a new Event by keeping only the Events where the previous and current values are not
==to each other.- Definition Classes
- Event
- def dedupWith(eq: (T, T) => Boolean): Event[T]
Build a new Event by keeping only those Event values where the equality predicate
eqapplied to the current and new values does not match.Build a new Event by keeping only those Event values where the equality predicate
eqapplied to the current and new values does not match.- Definition Classes
- Event
- def diff[CC[_], U](implicit arg0: Diffable[CC], toCC: <:<[T, CC[U]]): Event[Diff[CC, U]]
The Event that stores the difference between successive updates to the parent event.
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def filter(p: (T) => Boolean): Event[T]
Build a new Event by keeping only those Event values that match the predicate
p.Build a new Event by keeping only those Event values that match the predicate
p.- Definition Classes
- Event
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- def foldLeft[U](z: U)(f: (U, T) => U): Event[U]
Build a new Event by incrementally accumulating over events, starting with value
z.Build a new Event by incrementally accumulating over events, starting with value
z. Each intermediate aggregate is notified to the derived event.- Definition Classes
- Event
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def joinLast[U](other: Event[U]): Event[(T, U)]
Join two events into a new Event which notifies a tuple of the last value in each underlying event.
Join two events into a new Event which notifies a tuple of the last value in each underlying event.
- Definition Classes
- Event
- def map[U](f: (T) => U): Event[U]
Build a new Event by transforming each new event value with
f.Build a new Event by transforming each new event value with
f.- Definition Classes
- Event
- def merge[U >: T](other: Event[U]): Event[U]
Merge two events; the resulting event interleaves events from this and
other.Merge two events; the resulting event interleaves events from this and
other.- Definition Classes
- Event
- def mergeMap[U](f: (T) => Event[U]): Event[U]
The Event which merges the events resulting from
fapplied to each element in this Event.The Event which merges the events resulting from
fapplied to each element in this Event.- Definition Classes
- Event
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def patch[CC[_], U](implicit arg0: Diffable[CC], ev: <:<[T, Diff[CC, U]]): Event[CC[U]]
Patch up an Event of differences (like those produced by Event.diff) into an Event that reflects the current version of a data structure.
Patch up an Event of differences (like those produced by Event.diff) into an Event that reflects the current version of a data structure. That is:
(event: Event[CC[T]]).diff.patchis equivalent toevent- Definition Classes
- Event
- final def respond(s: (T) => Unit): Closable
Observe this event with function
s.Observe this event with function
s. Equivalent toregister(Witness(s)).- Definition Classes
- Event
- def select[U](other: Event[U]): Event[Either[T, U]]
Merge two Events of different types.
Merge two Events of different types.
- Definition Classes
- Event
- def sliding(n: Int): Event[Seq[T]]
Build a new Event representing a sliding window of at-most
n.Build a new Event representing a sliding window of at-most
n. Each event notified by the parent are added to a queue of size at-mostn. This queue is in turn notified to register of the returned event.- Definition Classes
- Event
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def take(howmany: Int): Event[T]
An event which consists of the first
howmanyvalues in the parent Event.An event which consists of the first
howmanyvalues in the parent Event.- Definition Classes
- Event
- def toFuture(): Future[T]
A Future which is satisfied by the first value observed.
A Future which is satisfied by the first value observed.
- Definition Classes
- Event
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- 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]) @native()
- def zip[U](other: Event[U]): Event[(T, U)]
Merge two event streams in lock-step, combining corresponding event values.
Merge two event streams in lock-step, combining corresponding event values.
- Definition Classes
- Event
- Note
This can be dangerous! Since the implementation needs to queue outstanding Event-values from the slower producer, if one Event outpaces another, this queue can grow in an unbounded fashion.