Var

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 apply(): T

   Returns current value of this Rx.

   Returns current value of this Rx. If this is called within the body of another Rx, this will create a dependency between the two Rxs. If this Rx contains an exception, that exception gets thrown.

   returns

   The current value of this Rx

   Definition Classes

   Rx

7. final def asInstanceOf[T0]: T0

   Definition Classes

   Any

8. def clone(): AnyRef

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws()

9. def currentValue: T

   Attributes

   protected[this]

   Definition Classes

   Rx

10. def debounce(interval: FiniteDuration)(implicit system: ActorSystem, ex: ExecutionContext): Rx[T]

    Creates a new Rx which debounces the old Rx; updates coming in within interval of a previous update get ignored.

    Creates a new Rx which debounces the old Rx; updates coming in within interval of a previous update get ignored. After the interval has passed, the last un-applied update (if any) will be applied to update the value of the Rx

    Definition Classes

    RxMethods

11. def debug(s: String): Unit

    Attributes

    protected[this]

    Definition Classes

    Node

12. def delay(delay: FiniteDuration)(implicit system: ActorSystem, ex: ExecutionContext): Rx[T]

    Creates a new Rx which debounces the old Rx; updates coming in within interval of a previous update get ignored.

    Creates a new Rx which debounces the old Rx; updates coming in within interval of a previous update get ignored. After the interval has passed, the last un-applied update (if any) will be applied to update the value of the Rx

    Definition Classes

    RxMethods

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

    Definition Classes

    AnyRef

14. def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

15. def filter(successPred: (T) ⇒ Boolean): Rx[T]

    Creates a new Rx which ignores specific Success conditions of the source Rx; it will not propagate the changes, and simply remain holding on to its last value if the new value fails the filter.

    Creates a new Rx which ignores specific Success conditions of the source Rx; it will not propagate the changes, and simply remain holding on to its last value if the new value fails the filter. Optionally takes a failurePred, allowing it to filter the Failure conditions as well.

    Definition Classes

    RxMethods

16. def filterAll[A >: T](predicate: (Try[A]) ⇒ Boolean): Rx[A]

    Identical to filter(), except the entire Try[T] is available to your predicate rather than just the T

    Identical to filter(), except the entire Try[T] is available to your predicate rather than just the T

    Definition Classes

    RxMethods

17. def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws()

18. def foreach(callback: (T) ⇒ Unit, skipInitial: Boolean = false): Obs

    Causes the given callback to run every time this Rx's value is changed.

    Causes the given callback to run every time this Rx's value is changed. Returns the Obs which executes this callback, which should generally be assigned to a variable to avoid it from being garbage-collected.

    Definition Classes

    RxMethods

19. def getChildren: Seq[Reactor[Nothing]]

    Returns the list of Reactors which are currently bound to this Emitter.

    Returns the list of Reactors which are currently bound to this Emitter.

    Definition Classes

    Emitter

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

    Definition Classes

    AnyRef → Any

21. def hashCode(): Int

    Definition Classes

    AnyRef → Any

22. final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

23. def level: Long

    Attributes

    protected[rx]

    Definition Classes

    Var → Node

24. def linkChild[R >: T](child: Reactor[R]): Unit

    Binds the Reactor child to this Emitter.

    Binds the Reactor child to this Emitter. Any pings by this Emitter will cause child to react.

    Definition Classes

    Emitter

25. def map[A](f: (T) ⇒ A): Rx[A]

    Creates a new Rx which contains the value of the old Rx, except transformed by some function.

    Creates a new Rx which contains the value of the old Rx, except transformed by some function.

    Definition Classes

    RxMethods

26. def mapAll[A](f: (Try[T]) ⇒ Try[A]): Rx[A]

    Identical to map(), except the entire Try[T] is available to your transformer rather than just the T

    Identical to map(), except the entire Try[T] is available to your transformer rather than just the T

    Definition Classes

    RxMethods

27. 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.

    Definition Classes

    Var → Node

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

    Definition Classes

    AnyRef

29. final def notify(): Unit

    Definition Classes

    AnyRef

30. final def notifyAll(): Unit

    Definition Classes

    AnyRef

31. def now: T

    Identical to apply(), except that it does not create a dependency if called within the body of another Rx

    Identical to apply(), except that it does not create a dependency if called within the body of another Rx

    returns

    The current value of this Rx

    Definition Classes

    Rx

32. def propagate[P]()(implicit arg0: Propagator[P]): P

    Definition Classes

    Rx

33. def reduce[A >: T](combiner: (A, A) ⇒ A): Rx[A]

    Creates a new Rx which combines the values of the source Rx according to the given combiner function.

    Creates a new Rx which combines the values of the source Rx according to the given combiner function. Failures are passed through directly, and transitioning from a Failure to a Success(s) re-starts the combining using the result s of the Success.

    Definition Classes

    RxMethods

34. def reduceAll[A >: T](combiner: (Try[A], Try[A]) ⇒ Try[A]): Rx[A]

    Identical to reduce(), except both Try[T]s are available to your combiner, rather than just the Ts.

    Identical to reduce(), except both Try[T]s are available to your combiner, rather than just the Ts.

    Definition Classes

    RxMethods

35. def skipFailures: Rx[T]

    Creates a new Rx which ignores Failure conditions of the source Rx; it will not propagate the changes, and simply remain holding on to its last value

    Creates a new Rx which ignores Failure conditions of the source Rx; it will not propagate the changes, and simply remain holding on to its last value

    Definition Classes

    RxMethods

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

    Definition Classes

    AnyRef

37. def toString(): String

    Definition Classes

    AnyRef → Any

38. def toTry: Try[T]

    Returns the current value stored within this Rx as a Try

    Returns the current value stored within this Rx as a Try

    Definition Classes

    Var → Rx

39. def update[P](newValue: ⇒ T)(implicit arg0: Propagator[P]): P

40. final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws()

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

    Definition Classes

    AnyRef

    Annotations

    @throws()

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

    Definition Classes

    AnyRef

    Annotations

    @throws()