ops

Type Members

1. class AkkaScheduler extends Scheduler

   A Scheduler that wraps an ActorSystem's scheduler.

2. class Async[+T, P] extends core.Rx[T] with Incrementing[T] with Reactor[Future[_]]

   A Rx which flattens out an Rx[Future[T]] into a Rx[T].

3. implicit final class AsyncRxOps[T] extends AnyVal

   Extends an Rx[Future[T]] to allow you to flatten it into an Rx[T] via the .async() method

4. class Debounce[+T] extends Dynamic[T]

   An Rx which wraps an existing Rx but only emits changes at most once every interval.

5. class Delay[+T] extends Dynamic[T]

   An Rx which wraps and existing Rx but delays the propagation by delay.

6. implicit final class RxOps[+T] extends AnyVal

7. trait Scheduler extends AnyRef

   A generic interface which can be used to schedule tasks.

8. class Timer[P] extends core.Rx[Long]

   An Rx which begins a propagation once every interval after an initial delay of delay.