Trait/Object

monifu.reactive.observables

GroupedObservable

Related Docs: object GroupedObservable | package observables

Permalink

trait GroupedObservable[K, +V] extends Observable[V] with LiftOperators2[K, V, GroupedObservable]

A GroupedObservable is an observable type generated by Observable.groupBy. It has the following properties:

- comes accompanied with a key property after which the grouping was made

- supports a single subscriber, throwing IllegalStateException if you attempt multiple subscriptions

Self Type
GroupedObservable[K, V]
Source
GroupedObservable.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. GroupedObservable
  2. LiftOperators2
  3. Observable
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Abstract Value Members

  1. abstract def key: K

    Permalink

    Returns the key associated with this grouped observable.

  2. abstract def onSubscribe(subscriber: Subscriber[V]): Unit

    Permalink

    Characteristic function for an Observable instance, that creates the subscription and that eventually starts the streaming of events to the given Observer, being meant to be overridden in custom combinators or in classes implementing Observable.

    Characteristic function for an Observable instance, that creates the subscription and that eventually starts the streaming of events to the given Observer, being meant to be overridden in custom combinators or in classes implementing Observable.

    This function is "unsafe" to call because it does not protect the calls to the given Observer implementation in regards to unexpected exceptions that violate the contract, therefore the given instance must respect its contract and not throw any exceptions when the observable calls onNext, onComplete and onError. If it does, then the behavior is undefined.

    Definition Classes
    Observable
    See also

    subscribe.

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 >: V](other: ⇒ Observable[U]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  4. def +:[U >: V](elem: U): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  5. def :+[U >: V](elem: U): GroupedObservable[K, U]

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

    Permalink
    Definition Classes
    AnyRef → Any
  7. def ambWith[U >: V](other: Observable[U]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  8. def asFuture(implicit s: Scheduler): Future[Option[V]]

    Permalink

    Returns the first generated result as a Future and then cancels the subscription.

    Returns the first generated result as a Future and then cancels the subscription.

    Definition Classes
    Observable
  9. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  10. def asyncBoundary[U >: V](overflowStrategy: Evicted, onOverflow: (Long) ⇒ U): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  11. def asyncBoundary(overflowStrategy: OverflowStrategy): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  12. def behavior[U >: V](initialValue: U)(implicit s: Scheduler): ConnectableObservable[U]

    Permalink

    Converts this observable into a multicast observable, useful for turning a cold observable into a hot one (i.e.

    Converts this observable into a multicast observable, useful for turning a cold observable into a hot one (i.e. whose source is shared by all observers). The underlying subject used is a BehaviorSubject.

    Definition Classes
    Observable
  13. def buffer(timespan: FiniteDuration, maxSize: Int): GroupedObservable[K, Seq[V]]

    Permalink
    Definition Classes
    LiftOperators2
  14. def buffer(timespan: FiniteDuration): GroupedObservable[K, Seq[V]]

    Permalink
    Definition Classes
    LiftOperators2
  15. def buffer(count: Int, skip: Int): GroupedObservable[K, Seq[V]]

    Permalink
    Definition Classes
    LiftOperators2
  16. def buffer(count: Int): GroupedObservable[K, Seq[V]]

    Permalink
    Definition Classes
    LiftOperators2
  17. def bufferIntrospective(maxSize: Int): Observable[List[V]]

    Permalink

    Buffers signals while busy, after which it emits the buffered events as a single bundle.

    Buffers signals while busy, after which it emits the buffered events as a single bundle.

    This operator starts applying back-pressure when the underlying buffer's size is exceeded.

    Definition Classes
    Observable
  18. def cache(maxCapacity: Int): Observable[V]

    Permalink

    Caches the emissions from the source Observable and replays them in order to any subsequent Subscribers.

    Caches the emissions from the source Observable and replays them in order to any subsequent Subscribers. This method has similar behavior to replay except that this auto-subscribes to the source Observable rather than returning a ConnectableObservable for which you must call connect to activate the subscription.

    When you call cache, it does not yet subscribe to the source Observable and so does not yet begin caching items. This only happens when the first Subscriber calls the resulting Observable's subscribe method.

    maxCapacity

    is the maximum buffer size after which old events start being dropped (according to what happens when using ReplaySubject.createWithSize)

    returns

    an Observable that, when first subscribed to, caches all of its items and notifications for the benefit of subsequent subscribers

    Definition Classes
    Observable
  19. def cache: Observable[V]

    Permalink

    Caches the emissions from the source Observable and replays them in order to any subsequent Subscribers.

    Caches the emissions from the source Observable and replays them in order to any subsequent Subscribers. This method has similar behavior to replay except that this auto-subscribes to the source Observable rather than returning a ConnectableObservable for which you must call connect to activate the subscription.

    When you call cache, it does not yet subscribe to the source Observable and so does not yet begin caching items. This only happens when the first Subscriber calls the resulting Observable's subscribe method.

    Note: You sacrifice the ability to cancel the origin when you use the cache operator so be careful not to use this on Observables that emit an infinite or very large number of items that will use up memory.

    returns

    an Observable that, when first subscribed to, caches all of its items and notifications for the benefit of subsequent subscribers

    Definition Classes
    Observable
  20. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  21. def collect[U](pf: PartialFunction[V, U]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  22. def combineLatest[U](other: Observable[U]): GroupedObservable[K, (V, U)]

    Permalink
    Definition Classes
    LiftOperators2
  23. def combineLatestDelayError[U](other: Observable[U]): GroupedObservable[K, (V, U)]

    Permalink
    Definition Classes
    LiftOperators2
  24. def complete: GroupedObservable[K, Nothing]

    Permalink
    Definition Classes
    LiftOperators2
  25. def concat[U](implicit ev: <:<[V, Observable[U]]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  26. def concatDelayError[U](implicit ev: <:<[V, Observable[U]]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  27. def concatMap[U](f: (V) ⇒ Observable[U]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  28. def concatMapDelayError[U](f: (V) ⇒ Observable[U]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  29. def count: GroupedObservable[K, Long]

    Permalink
    Definition Classes
    LiftOperators2
  30. def debounce[U](selector: (V) ⇒ Observable[Any], f: (V) ⇒ Observable[U]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  31. def debounce(selector: (V) ⇒ Observable[Any]): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  32. def debounce[U](timeout: FiniteDuration, f: (V) ⇒ Observable[U]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  33. def debounce(timeout: FiniteDuration): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  34. def debounceRepeated(period: FiniteDuration): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  35. def defaultIfEmpty[U >: V](default: U): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  36. def delay[U](selector: (V) ⇒ Observable[U]): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  37. def delay(duration: FiniteDuration): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  38. def delaySubscription(timespan: FiniteDuration): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  39. def delaySubscription[U](trigger: Observable[U]): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  40. def distinct[U](fn: (V) ⇒ U): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  41. def distinct: GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  42. def distinctUntilChanged[U](fn: (V) ⇒ U): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  43. def distinctUntilChanged: GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  44. def doOnCanceled(cb: ⇒ Unit): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  45. def doOnComplete(cb: ⇒ Unit): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  46. def doOnError(cb: (Throwable) ⇒ Unit): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  47. def doOnStart(cb: (V) ⇒ Unit): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  48. def doWork(cb: (V) ⇒ Unit): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  49. def drop(n: Int): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  50. def dropByTimespan(timespan: FiniteDuration): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  51. def dropWhile(p: (V) ⇒ Boolean): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  52. def dropWhileWithIndex(p: (V, Int) ⇒ Boolean): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  53. def dump(prefix: String, out: PrintStream = System.out): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  54. def echoOnce(timeout: FiniteDuration): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  55. def echoRepeated(timeout: FiniteDuration): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  56. def endWith[U >: V](elems: U*): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  57. def endWithError(error: Throwable): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  58. final def eq(arg0: AnyRef): Boolean

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

    Permalink
    Definition Classes
    AnyRef → Any
  60. def error: GroupedObservable[K, Throwable]

    Permalink
    Definition Classes
    LiftOperators2
  61. def exists(p: (V) ⇒ Boolean): GroupedObservable[K, Boolean]

    Permalink
    Definition Classes
    LiftOperators2
  62. def filter(p: (V) ⇒ Boolean): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  63. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  64. def find(p: (V) ⇒ Boolean): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  65. def firstOrElse[U >: V](default: ⇒ U): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  66. def flatMap[U](f: (V) ⇒ Observable[U]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  67. def flatMapDelayError[U](f: (V) ⇒ Observable[U]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  68. def flatMapLatest[U](f: (V) ⇒ Observable[U]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  69. def flatScan[R](initial: R)(op: (R, V) ⇒ Observable[R]): GroupedObservable[K, R]

    Permalink
    Definition Classes
    LiftOperators2
  70. def flatScanDelayError[R](initial: R)(op: (R, V) ⇒ Observable[R]): GroupedObservable[K, R]

    Permalink
    Definition Classes
    LiftOperators2
  71. def flatten[U](implicit ev: <:<[V, Observable[U]]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  72. def flattenDelayError[U](implicit ev: <:<[V, Observable[U]]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  73. def flattenLatest[U](implicit ev: <:<[V, Observable[U]]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  74. def foldLeft[R](initial: R)(op: (R, V) ⇒ R): GroupedObservable[K, R]

    Permalink
    Definition Classes
    LiftOperators2
  75. def forAll(p: (V) ⇒ Boolean): GroupedObservable[K, Boolean]

    Permalink
    Definition Classes
    LiftOperators2
  76. def foreach(cb: (V) ⇒ Unit)(implicit s: Scheduler): Unit

    Permalink

    Subscribes to the source Observable and foreach element emitted by the source it executes the given callback.

    Subscribes to the source Observable and foreach element emitted by the source it executes the given callback.

    Definition Classes
    Observable
  77. final def getClass(): Class[_]

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

    Permalink
    Definition Classes
    LiftOperators2
  79. def groupBy[K](keySelector: (V) ⇒ K): GroupedObservable[K, GroupedObservable[K, V]]

    Permalink
    Definition Classes
    LiftOperators2
  80. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  81. def head: GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  82. def headOrElse[B >: V](default: ⇒ B): GroupedObservable[K, B]

    Permalink
    Definition Classes
    LiftOperators2
  83. def ignoreElements: GroupedObservable[K, Nothing]

    Permalink
    Definition Classes
    LiftOperators2
  84. def isEmpty: GroupedObservable[K, Boolean]

    Permalink
    Definition Classes
    LiftOperators2
  85. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  86. def last: GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  87. def lift[U](f: (Observable[V]) ⇒ Observable[U]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  88. def liftToSelf[U](f: (Observable[V]) ⇒ Observable[U]): GroupedObservable[K, U]

    Permalink
    Attributes
    protected
    Definition Classes
    GroupedObservableLiftOperators2
  89. def map[U](f: (V) ⇒ U): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  90. def materialize: GroupedObservable[K, Notification[V]]

    Permalink
    Definition Classes
    LiftOperators2
  91. def max[U >: V](implicit ev: Ordering[U]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  92. def maxBy[U](f: (V) ⇒ U)(implicit ev: Ordering[U]): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  93. def merge[U](overflowStrategy: Evicted, onOverflow: (Long) ⇒ U)(implicit ev: <:<[V, Observable[U]]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  94. def merge[U](overflowStrategy: OverflowStrategy)(implicit ev: <:<[V, Observable[U]]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  95. def merge[U](implicit ev: <:<[V, Observable[U]]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  96. def mergeDelayErrors[U](overflowStrategy: Evicted, onOverflow: (Long) ⇒ U)(implicit ev: <:<[V, Observable[U]]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  97. def mergeDelayErrors[U](overflowStrategy: OverflowStrategy)(implicit ev: <:<[V, Observable[U]]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  98. def mergeDelayErrors[U](implicit ev: <:<[V, Observable[U]]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  99. def mergeMap[U](f: (V) ⇒ Observable[U]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  100. def mergeMapDelayErrors[U](f: (V) ⇒ Observable[U]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  101. def min[U >: V](implicit ev: Ordering[U]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  102. def minBy[U](f: (V) ⇒ U)(implicit ev: Ordering[U]): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  103. def multicast[U >: V, R](subject: Subject[U, R])(implicit s: Scheduler): ConnectableObservable[R]

    Permalink

    Converts this observable into a multicast observable, useful for turning a cold observable into a hot one (i.e.

    Converts this observable into a multicast observable, useful for turning a cold observable into a hot one (i.e. whose source is shared by all observers).

    Definition Classes
    Observable
  104. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  105. def nonEmpty: GroupedObservable[K, Boolean]

    Permalink
    Definition Classes
    LiftOperators2
  106. final def notify(): Unit

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

    Permalink
    Definition Classes
    AnyRef
  108. def onErrorFallbackTo[U >: V](that: ⇒ Observable[U]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  109. def onErrorRecoverWith[U >: V](pf: PartialFunction[Throwable, Observable[U]]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  110. def onErrorRetry(maxRetries: Long): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  111. def onErrorRetryIf(p: (Throwable) ⇒ Boolean): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  112. def onErrorRetryUnlimited: GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  113. def onSubscribe(observer: Observer[V])(implicit s: Scheduler): Unit

    Permalink

    Subscribes to the stream.

    Subscribes to the stream.

    This function is "unsafe" to call because it does not protect the calls to the given Observer implementation in regards to unexpected exceptions that violate the contract, therefore the given instance must respect its contract and not throw any exceptions when the observable calls onNext, onComplete and onError. If it does, then the behavior is undefined.

    observer

    is an Observer that respects the Monifu Rx contract

    s

    is the Scheduler used for creating the subscription

    Definition Classes
    Observable
  114. def publish(implicit s: Scheduler): ConnectableObservable[V]

    Permalink

    Converts this observable into a multicast observable, useful for turning a cold observable into a hot one (i.e.

    Converts this observable into a multicast observable, useful for turning a cold observable into a hot one (i.e. whose source is shared by all observers). The underlying subject used is a PublishSubject.

    Definition Classes
    Observable
  115. def publishLast(implicit s: Scheduler): ConnectableObservable[V]

    Permalink

    Converts this observable into a multicast observable, useful for turning a cold observable into a hot one (i.e.

    Converts this observable into a multicast observable, useful for turning a cold observable into a hot one (i.e. whose source is shared by all observers). The underlying subject used is a AsyncSubject.

    Definition Classes
    Observable
  116. def reduce[U >: V](op: (U, U) ⇒ U): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  117. def repeat: GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  118. def replay(bufferSize: Int)(implicit s: Scheduler): ConnectableObservable[V]

    Permalink

    Converts this observable into a multicast observable, useful for turning a cold observable into a hot one (i.e.

    Converts this observable into a multicast observable, useful for turning a cold observable into a hot one (i.e. whose source is shared by all observers). The underlying subject used is a ReplaySubject.

    bufferSize

    is the size of the buffer limiting the number of items that can be replayed (on overflow the head starts being dropped)

    Definition Classes
    Observable
  119. def replay(implicit s: Scheduler): ConnectableObservable[V]

    Permalink

    Converts this observable into a multicast observable, useful for turning a cold observable into a hot one (i.e.

    Converts this observable into a multicast observable, useful for turning a cold observable into a hot one (i.e. whose source is shared by all observers). The underlying subject used is a ReplaySubject.

    Definition Classes
    Observable
  120. def sample[U](sampler: Observable[U]): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  121. def sample(initialDelay: FiniteDuration, delay: FiniteDuration): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  122. def sample(delay: FiniteDuration): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  123. def sampleRepeated[U](sampler: Observable[U]): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  124. def sampleRepeated(initialDelay: FiniteDuration, delay: FiniteDuration): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  125. def sampleRepeated(delay: FiniteDuration): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  126. def scan[R](initial: R)(op: (R, V) ⇒ R): GroupedObservable[K, R]

    Permalink
    Definition Classes
    LiftOperators2
  127. def share(implicit s: Scheduler): Observable[V]

    Permalink

    Returns a new Observable that multi-casts (shares) the original Observable.

    Returns a new Observable that multi-casts (shares) the original Observable.

    Definition Classes
    Observable
  128. def startWith[U >: V](elems: U*): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  129. def subscribe(nextFn: (V) ⇒ Future[Ack])(implicit s: Scheduler): BooleanCancelable

    Permalink

    Subscribes to the stream.

    Subscribes to the stream.

    returns

    a subscription that can be used to cancel the streaming.

    Definition Classes
    Observable
  130. def subscribe()(implicit s: Scheduler): Cancelable

    Permalink

    Subscribes to the stream.

    Subscribes to the stream.

    returns

    a subscription that can be used to cancel the streaming.

    Definition Classes
    Observable
  131. def subscribe(nextFn: (V) ⇒ Future[Ack], errorFn: (Throwable) ⇒ Unit)(implicit s: Scheduler): BooleanCancelable

    Permalink

    Subscribes to the stream.

    Subscribes to the stream.

    returns

    a subscription that can be used to cancel the streaming.

    Definition Classes
    Observable
  132. def subscribe(nextFn: (V) ⇒ Future[Ack], errorFn: (Throwable) ⇒ Unit, completedFn: () ⇒ Unit)(implicit s: Scheduler): BooleanCancelable

    Permalink

    Subscribes to the stream.

    Subscribes to the stream.

    returns

    a subscription that can be used to cancel the streaming.

    Definition Classes
    Observable
  133. def subscribe(observer: Observer[V])(implicit s: Scheduler): BooleanCancelable

    Permalink

    Subscribes to the stream.

    Subscribes to the stream.

    returns

    a subscription that can be used to cancel the streaming.

    Definition Classes
    Observable
  134. def subscribe(subscriber: Subscriber[V]): BooleanCancelable

    Permalink

    Subscribes to the stream.

    Subscribes to the stream.

    returns

    a subscription that can be used to cancel the streaming.

    Definition Classes
    Observable
  135. def subscribeOn(s: Scheduler): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  136. def sum[U >: V](implicit ev: Numeric[U]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  137. def switch[U](implicit ev: <:<[V, Observable[U]]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  138. def switchMap[U](f: (V) ⇒ Observable[U]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  139. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef
  140. def tail: GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  141. def take(timespan: FiniteDuration): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  142. def take(n: Long): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  143. def takeRight(n: Int): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  144. def takeWhile(p: (V) ⇒ Boolean): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  145. def takeWhileNotCanceled(c: BooleanCancelable): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  146. def throttleFirst(interval: FiniteDuration): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  147. def throttleLast(period: FiniteDuration): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  148. def throttleWithTimeout(timeout: FiniteDuration): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  149. def timeout[U >: V](timeout: FiniteDuration, backup: Observable[U]): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  150. def timeout(timeout: FiniteDuration): GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  151. def toReactive[U >: V](implicit s: Scheduler): Publisher[U]

    Permalink

    Wraps this Observable into a org.reactivestreams.Publisher.

    Wraps this Observable into a org.reactivestreams.Publisher. See the Reactive Streams protocol that Monifu implements.

    Definition Classes
    Observable
  152. def toString(): String

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

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

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

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  156. def whileBusyBuffer[U >: V](overflowStrategy: Evicted, onOverflow: (Long) ⇒ U): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  157. def whileBusyBuffer[U >: V](overflowStrategy: Synchronous): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  158. def whileBusyDropEvents[U >: V](onOverflow: (Long) ⇒ U): GroupedObservable[K, U]

    Permalink
    Definition Classes
    LiftOperators2
  159. def whileBusyDropEvents: GroupedObservable[K, V]

    Permalink
    Definition Classes
    LiftOperators2
  160. def window(timespan: FiniteDuration, maxCount: Int): GroupedObservable[K, Observable[V]]

    Permalink
    Definition Classes
    LiftOperators2
  161. def window(timespan: FiniteDuration): GroupedObservable[K, Observable[V]]

    Permalink
    Definition Classes
    LiftOperators2
  162. def window(count: Int, skip: Int): GroupedObservable[K, Observable[V]]

    Permalink
    Definition Classes
    LiftOperators2
  163. def window(count: Int): GroupedObservable[K, Observable[V]]

    Permalink
    Definition Classes
    LiftOperators2
  164. def zip[U](other: Observable[U]): GroupedObservable[K, (V, U)]

    Permalink
    Definition Classes
    LiftOperators2
  165. def zipWithIndex: GroupedObservable[K, (V, Long)]

    Permalink
    Definition Classes
    LiftOperators2

Inherited from LiftOperators2[K, V, GroupedObservable]

Inherited from Observable[V]

Inherited from AnyRef

Inherited from Any

Ungrouped