rx.core

Obs

class Obs extends Reactor[Any]

An Obs is something that produces side-effects when the source Rx changes. An Obs is always run right at the end of every propagation wave, ensuring it is only called once per wave (in contrast with Rxs, which may update multiple times before settling).

Linear Supertypes
Reactor[Any], Node, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Obs
  2. Reactor
  3. Node
  4. AnyRef
  5. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new Obs(source: Emitter[Any], callback: () ⇒ Unit, name: String = "", skipInitial: Boolean = false)

    callback

    a callback to run when this Obs is pinged

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any

  3. final def ##(): Int

    Definition Classes
    AnyRef → Any

  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any

  6. def alive: Boolean

    Whether or not this Reactor is currently alive.

    Whether or not this Reactor is currently alive. Only Reactors which are alive will receive updates and propagate changes.

    Definition Classes
    Reactor

  7. def ancestors: Set[Emitter[_]]

    All parents, parent's parents, etc.

    All parents, parent's parents, etc. recursively.

    Definition Classes
    Reactor

  8. final def asInstanceOf[T0]: T0

    Definition Classes
    Any

  9. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  10. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  11. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any

  12. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )

  13. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any

  14. def hashCode(): Int

    Definition Classes
    AnyRef → Any

  15. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any

  16. def kill(): Unit

    Stops this Reactor from listening for updates.

    Stops this Reactor from listening for updates. Obss would stop triggering, Rxs would stop updating and propagating. In Scala-JS, this is necessary to allow the Reactor to be garbage collected, while in Scala-JVM this is unnecessary because of weak references.

    .kill() is irreversible.

    Definition Classes
    Reactor

  17. def level: Long

    A number giving an approximate ordering of the current Node in the dataflow graph it is part of.

    A number giving an approximate ordering of the current Node in the dataflow graph it is part of.

    Vars have it set to 0 and Obs have it set to Long.MaxValue because they're always the root and leaves of the graph. For other Rxs it depends on their location within the dataflow graph, and can change over time if the shape of the graph is changing.

    Definition Classes
    Obs → Node

  18. val name: String

    The name of this object, generally passed in as a String when it is created.

    The name of this object, generally passed in as a String when it is created.

    This can be inspected later, and is handy for debugging and logging purposes.

    Definition Classes
    Obs → Node

  19. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  20. final def notify(): Unit

    Definition Classes
    AnyRef

  21. final def notifyAll(): Unit

    Definition Classes
    AnyRef

  22. def parents: Set[Emitter[Any]]

    The list of Emitters which this Reactor is currently bound to.

    The list of Emitters which this Reactor is currently bound to.

    Any of these Emitters emitting a ping will cause this Reactor to react.

    Definition Classes
    Obs → Reactor

  23. def ping[P](incoming: Set[Emitter[_]])(implicit arg0: Propagator[P]): Set[Reactor[_]]

    Pings this Reactor with some Emitters, causing it to react.

    Pings this Reactor with some Emitters, causing it to react.

    Definition Classes
    Obs → Reactor

  24. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef

  25. def toString(): String

    Definition Classes
    AnyRef → Any

  26. def trigger(): Set[Reactor[_]]

    Manually trigger this observer, causing its callback to run.

  27. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  28. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  29. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from Reactor[Any]

Inherited from Node

Inherited from AnyRef

Inherited from Any

Ungrouped