Trait

monifu.reactive.observables

LiftOperators1

Related Doc: package observables

Permalink

trait LiftOperators1[+T, Self[+U] <: Observable[U]] extends AnyRef

An interface to be extended in Observable types that want to preserve the return type when applying operators. For example the result of ConnectableObservable.map is still a ConnectableObservable and this interface represents an utility to do just that.

Self Type
LiftOperators1[T, Self] with Observable[T]
Source
LiftOperators1.scala
Linear Supertypes
Known Subclasses
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. LiftOperators1
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Abstract Value Members

  1. abstract def liftToSelf[U](f: (Observable[T]) ⇒ Observable[U]): Self[U]

    Permalink
    Attributes
    protected

Concrete Value Members

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

    Permalink
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  3. def ++[U >: T](other: ⇒ Observable[U]): Self[U]

    Permalink
  4. def +:[U >: T](elem: U): Self[U]

    Permalink
  5. def :+[U >: T](elem: U): Self[U]

    Permalink
  6. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  7. def ambWith[U >: T](other: Observable[U]): Self[U]

    Permalink
  8. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  9. def asyncBoundary[U >: T](overflowStrategy: Evicted, onOverflow: (Long) ⇒ U): Self[U]

    Permalink
  10. def asyncBoundary(overflowStrategy: OverflowStrategy): Self[T]

    Permalink
  11. def buffer(timespan: FiniteDuration, maxSize: Int): Self[Seq[T]]

    Permalink
  12. def buffer(timespan: FiniteDuration): Self[Seq[T]]

    Permalink
  13. def buffer(count: Int, skip: Int): Self[Seq[T]]

    Permalink
  14. def buffer(count: Int): Self[Seq[T]]

    Permalink
  15. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  16. def collect[U](pf: PartialFunction[T, U]): Self[U]

    Permalink
  17. def combineLatest[U](other: Observable[U]): Self[(T, U)]

    Permalink
  18. def combineLatestDelayError[U](other: Observable[U]): Self[(T, U)]

    Permalink
  19. def complete: Self[Nothing]

    Permalink
  20. def concat[U](implicit ev: <:<[T, Observable[U]]): Self[U]

    Permalink
  21. def concatDelayError[U](implicit ev: <:<[T, Observable[U]]): Self[U]

    Permalink
  22. def concatMap[U](f: (T) ⇒ Observable[U]): Self[U]

    Permalink
  23. def concatMapDelayError[U](f: (T) ⇒ Observable[U]): Self[U]

    Permalink
  24. def count: Self[Long]

    Permalink
  25. def debounce[U](selector: (T) ⇒ Observable[Any], f: (T) ⇒ Observable[U]): Self[U]

    Permalink
  26. def debounce(selector: (T) ⇒ Observable[Any]): Self[T]

    Permalink
  27. def debounce[U](timeout: FiniteDuration, f: (T) ⇒ Observable[U]): Self[U]

    Permalink
  28. def debounce(timeout: FiniteDuration): Self[T]

    Permalink
  29. def debounceRepeated(period: FiniteDuration): Self[T]

    Permalink
  30. def defaultIfEmpty[U >: T](default: U): Self[U]

    Permalink
  31. def delay[U](selector: (T) ⇒ Observable[U]): Self[T]

    Permalink
  32. def delay(duration: FiniteDuration): Self[T]

    Permalink
  33. def delaySubscription(timespan: FiniteDuration): Self[T]

    Permalink
  34. def delaySubscription[U](trigger: Observable[U]): Self[T]

    Permalink
  35. def distinct[U](fn: (T) ⇒ U): Self[T]

    Permalink
  36. def distinct: Self[T]

    Permalink
  37. def distinctUntilChanged[U](fn: (T) ⇒ U): Self[T]

    Permalink
  38. def distinctUntilChanged: Self[T]

    Permalink
  39. def doOnCanceled(cb: ⇒ Unit): Self[T]

    Permalink
  40. def doOnComplete(cb: ⇒ Unit): Self[T]

    Permalink
  41. def doOnError(cb: (Throwable) ⇒ Unit): Self[T]

    Permalink
  42. def doOnStart(cb: (T) ⇒ Unit): Self[T]

    Permalink
  43. def doWork(cb: (T) ⇒ Unit): Self[T]

    Permalink
  44. def drop(n: Int): Self[T]

    Permalink
  45. def dropByTimespan(timespan: FiniteDuration): Self[T]

    Permalink
  46. def dropWhile(p: (T) ⇒ Boolean): Self[T]

    Permalink
  47. def dropWhileWithIndex(p: (T, Int) ⇒ Boolean): Self[T]

    Permalink
  48. def dump(prefix: String, out: PrintStream = System.out): Self[T]

    Permalink
  49. def echoOnce(timeout: FiniteDuration): Self[T]

    Permalink
  50. def echoRepeated(timeout: FiniteDuration): Self[T]

    Permalink
  51. def endWith[U >: T](elems: U*): Self[U]

    Permalink
  52. def endWithError(error: Throwable): Self[T]

    Permalink
  53. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  54. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  55. def error: Self[Throwable]

    Permalink
  56. def exists(p: (T) ⇒ Boolean): Self[Boolean]

    Permalink
  57. def filter(p: (T) ⇒ Boolean): Self[T]

    Permalink
  58. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  59. def find(p: (T) ⇒ Boolean): Self[T]

    Permalink
  60. def firstOrElse[U >: T](default: ⇒ U): Self[U]

    Permalink
  61. def flatMap[U](f: (T) ⇒ Observable[U]): Self[U]

    Permalink
  62. def flatMapDelayError[U](f: (T) ⇒ Observable[U]): Self[U]

    Permalink
  63. def flatMapLatest[U](f: (T) ⇒ Observable[U]): Self[U]

    Permalink
  64. def flatScan[R](initial: R)(op: (R, T) ⇒ Observable[R]): Self[R]

    Permalink
  65. def flatScanDelayError[R](initial: R)(op: (R, T) ⇒ Observable[R]): Self[R]

    Permalink
  66. def flatten[U](implicit ev: <:<[T, Observable[U]]): Self[U]

    Permalink
  67. def flattenDelayError[U](implicit ev: <:<[T, Observable[U]]): Self[U]

    Permalink
  68. def flattenLatest[U](implicit ev: <:<[T, Observable[U]]): Self[U]

    Permalink
  69. def foldLeft[R](initial: R)(op: (R, T) ⇒ R): Self[R]

    Permalink
  70. def forAll(p: (T) ⇒ Boolean): Self[Boolean]

    Permalink
  71. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any
  72. def groupBy[K](keyBufferSize: Int, keySelector: (T) ⇒ K): Self[GroupedObservable[K, T]]

    Permalink
  73. def groupBy[K](keySelector: (T) ⇒ K): Self[GroupedObservable[K, T]]

    Permalink
  74. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  75. def head: Self[T]

    Permalink
  76. def headOrElse[B >: T](default: ⇒ B): Self[B]

    Permalink
  77. def ignoreElements: Self[Nothing]

    Permalink
  78. def isEmpty: Self[Boolean]

    Permalink
  79. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  80. def last: Self[T]

    Permalink
  81. def lift[U](f: (Observable[T]) ⇒ Observable[U]): Self[U]

    Permalink
  82. def map[U](f: (T) ⇒ U): Self[U]

    Permalink
  83. def materialize: Self[Notification[T]]

    Permalink
  84. def max[U >: T](implicit ev: Ordering[U]): Self[U]

    Permalink
  85. def maxBy[U](f: (T) ⇒ U)(implicit ev: Ordering[U]): Self[T]

    Permalink
  86. def merge[U](overflowStrategy: Evicted, onOverflow: (Long) ⇒ U)(implicit ev: <:<[T, Observable[U]]): Self[U]

    Permalink
  87. def merge[U](overflowStrategy: OverflowStrategy)(implicit ev: <:<[T, Observable[U]]): Self[U]

    Permalink
  88. def merge[U](implicit ev: <:<[T, Observable[U]]): Self[U]

    Permalink
  89. def mergeDelayErrors[U](overflowStrategy: Evicted, onOverflow: (Long) ⇒ U)(implicit ev: <:<[T, Observable[U]]): Self[U]

    Permalink
  90. def mergeDelayErrors[U](overflowStrategy: OverflowStrategy)(implicit ev: <:<[T, Observable[U]]): Self[U]

    Permalink
  91. def mergeDelayErrors[U](implicit ev: <:<[T, Observable[U]]): Self[U]

    Permalink
  92. def mergeMap[U](f: (T) ⇒ Observable[U]): Self[U]

    Permalink
  93. def mergeMapDelayErrors[U](f: (T) ⇒ Observable[U]): Self[U]

    Permalink
  94. def min[U >: T](implicit ev: Ordering[U]): Self[U]

    Permalink
  95. def minBy[U](f: (T) ⇒ U)(implicit ev: Ordering[U]): Self[T]

    Permalink
  96. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  97. def nonEmpty: Self[Boolean]

    Permalink
  98. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  99. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
  100. def onErrorFallbackTo[U >: T](that: ⇒ Observable[U]): Self[U]

    Permalink
  101. def onErrorRecoverWith[U >: T](pf: PartialFunction[Throwable, Observable[U]]): Self[U]

    Permalink
  102. def onErrorRetry(maxRetries: Long): Self[T]

    Permalink
  103. def onErrorRetryIf(p: (Throwable) ⇒ Boolean): Self[T]

    Permalink
  104. def onErrorRetryUnlimited: Self[T]

    Permalink
  105. def reduce[U >: T](op: (U, U) ⇒ U): Self[U]

    Permalink
  106. def repeat: Self[T]

    Permalink
  107. def sample[U](sampler: Observable[U]): Self[T]

    Permalink
  108. def sample(initialDelay: FiniteDuration, delay: FiniteDuration): Self[T]

    Permalink
  109. def sample(delay: FiniteDuration): Self[T]

    Permalink
  110. def sampleRepeated[U](sampler: Observable[U]): Self[T]

    Permalink
  111. def sampleRepeated(initialDelay: FiniteDuration, delay: FiniteDuration): Self[T]

    Permalink
  112. def sampleRepeated(delay: FiniteDuration): Self[T]

    Permalink
  113. def scan[R](initial: R)(op: (R, T) ⇒ R): Self[R]

    Permalink
  114. def startWith[U >: T](elems: U*): Self[U]

    Permalink
  115. def subscribeOn(s: Scheduler): Self[T]

    Permalink
  116. def sum[U >: T](implicit ev: Numeric[U]): Self[U]

    Permalink
  117. def switch[U](implicit ev: <:<[T, Observable[U]]): Self[U]

    Permalink
  118. def switchMap[U](f: (T) ⇒ Observable[U]): Self[U]

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

    Permalink
    Definition Classes
    AnyRef
  120. def tail: Self[T]

    Permalink
  121. def take(timespan: FiniteDuration): Self[T]

    Permalink
  122. def take(n: Long): Self[T]

    Permalink
  123. def takeRight(n: Int): Self[T]

    Permalink
  124. def takeWhile(p: (T) ⇒ Boolean): Self[T]

    Permalink
  125. def takeWhileNotCanceled(c: BooleanCancelable): Self[T]

    Permalink
  126. def throttleFirst(interval: FiniteDuration): Self[T]

    Permalink
  127. def throttleLast(period: FiniteDuration): Self[T]

    Permalink
  128. def throttleWithTimeout(timeout: FiniteDuration): Self[T]

    Permalink
  129. def timeout[U >: T](timeout: FiniteDuration, backup: Observable[U]): Self[U]

    Permalink
  130. def timeout(timeout: FiniteDuration): Self[T]

    Permalink
  131. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any
  132. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  133. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  134. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  135. def whileBusyBuffer[U >: T](overflowStrategy: Evicted, onOverflow: (Long) ⇒ U): Self[U]

    Permalink
  136. def whileBusyBuffer[U >: T](overflowStrategy: Synchronous): Self[U]

    Permalink
  137. def whileBusyDropEvents[U >: T](onOverflow: (Long) ⇒ U): Self[U]

    Permalink
  138. def whileBusyDropEvents: Self[T]

    Permalink
  139. def window(timespan: FiniteDuration, maxCount: Int): Self[Observable[T]]

    Permalink
  140. def window(timespan: FiniteDuration): Self[Observable[T]]

    Permalink
  141. def window(count: Int, skip: Int): Self[Observable[T]]

    Permalink
  142. def window(count: Int): Self[Observable[T]]

    Permalink
  143. def zip[U](other: Observable[U]): Self[(T, U)]

    Permalink
  144. def zipWithIndex: Self[(T, Long)]

    Permalink

Inherited from AnyRef

Inherited from Any

Ungrouped