ErrorDelayingObservable

Value Members

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

   

   Definition Classes

   Any

2. final def ##(): Int

   

   Definition Classes

   Any

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

   

   Definition Classes

   Any

4. final def asInstanceOf[T0]: T0

   

   Definition Classes

   Any

5. def concat[U](implicit evidence: <:<[Observable[T], Observable[Observable[U]]]): Observable[U]

   

   EXPERIMENTAL Concatenates the Observable sequence of Observables into a single sequence by subscribing to each inner Observable, one after the other, one at a time and delays any errors till the all inner and the outer Observables terminate.

   EXPERIMENTAL Concatenates the Observable sequence of Observables into a single sequence by subscribing to each inner Observable, one after the other, one at a time and delays any errors till the all inner and the outer Observables terminate.

   Backpressure:

   Fully supports backpressure.

   Scheduler:

   This method does not operate by default on a particular Scheduler.

   returns

   the new Observable with the concatenating behavior

   Annotations

   @Experimental()

6. def concatMap[R](f: (T) ⇒ Observable[R]): Observable[R]

   

   EXPERIMENTAL Maps each of the items into an Observable, subscribes to them one after the other, one at a time and emits their values in order while delaying any error from either this or any of the inner Observables till all of them terminate.

   EXPERIMENTAL Maps each of the items into an Observable, subscribes to them one after the other, one at a time and emits their values in order while delaying any error from either this or any of the inner Observables till all of them terminate.

   Backpressure:

   Fully supports backpressure.

   Scheduler:

   This method does not operate by default on a particular Scheduler.

   f

   the function that maps the items of this Observable into the inner Observables.

   returns

   the new Observable instance with the concatenation behavior

   Annotations

   @Experimental()

7. def flatten[U](maxConcurrent: Int)(implicit evidence: <:<[Observable[T], Observable[Observable[U]]]): Observable[U]

   

   EXPERIMENTAL Flattens an Observable that emits Observables into one Observable, in a way that allows an Observer to receive all successfully emitted items from all of the source Observables without being interrupted by an error notification from one of them, while limiting the number of concurrent subscriptions to these Observables.

   EXPERIMENTAL Flattens an Observable that emits Observables into one Observable, in a way that allows an Observer to receive all successfully emitted items from all of the source Observables without being interrupted by an error notification from one of them, while limiting the number of concurrent subscriptions to these Observables.

   This behaves like flatten except that if any of the merged Observables notify of an error via onError, it will refrain from propagating that error notification until all of the merged Observables have finished emitting items.

   

   Even if multiple merged Observables send onError notifications, it will only invoke the onError method of its Observers once.

   Scheduler:

   This method does not operate by default on a particular Scheduler.

   maxConcurrent

   the maximum number of Observables that may be subscribed to concurrently

   returns

   an Observable that emits all of the items emitted by the Observables emitted by this

   Annotations

   @Experimental()

   Since

   (if this graduates from Experimental/Beta to supported, replace this parenthetical with the release number)

   See also

   ReactiveX operators documentation: Merge

8. def flatten[U](implicit evidence: <:<[Observable[T], Observable[Observable[U]]]): Observable[U]

   

   EXPERIMENTAL Flattens an Observable that emits Observables into one Observable, in a way that allows an Observer to receive all successfully emitted items from all of the source Observables without being interrupted by an error notification from one of them, while limiting the number of concurrent subscriptions to these Observables.

   EXPERIMENTAL Flattens an Observable that emits Observables into one Observable, in a way that allows an Observer to receive all successfully emitted items from all of the source Observables without being interrupted by an error notification from one of them, while limiting the number of concurrent subscriptions to these Observables.

   This behaves like flatten except that if any of the merged Observables notify of an error via onError, it will refrain from propagating that error notification until all of the merged Observables have finished emitting items.

   

   Even if multiple merged Observables send onError notifications, it will only invoke the onError method of its Observers once.

   Scheduler:

   This method does not operate by default on a particular Scheduler.

   returns

   an Observable that emits all of the items emitted by the Observables emitted by this

   Annotations

   @Experimental()

   See also

   ReactiveX operators documentation: Merge

9. def getClass(): Class[_ <: AnyVal]

   

   Definition Classes

   AnyVal → Any

10. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

11. def merge[U >: T](that: Observable[U]): Observable[U]

    

    This behaves like rx.lang.scala.Observable.merge except that if any of the merged Observables notify of an error via onError, it will refrain from propagating that error notification until all of the merged Observables have finished emitting items.

    This behaves like rx.lang.scala.Observable.merge except that if any of the merged Observables notify of an error via onError, it will refrain from propagating that error notification until all of the merged Observables have finished emitting items.

    

    Even if multiple merged Observables send onError notifications, it will only invoke the onError method of its Observers once.

    This method allows an Observer to receive all successfully emitted items from all of the source Observables without being interrupted by an error notification from one of them.

    that

    an Observable to be merged

    returns

    an Observable that emits items that are the result of flattening the items emitted by this and that

12. val o: Observable[T]

    

13. def switch[U](implicit evidence: <:<[Observable[T], Observable[Observable[U]]]): Observable[U]

    

    EXPERIMENTAL Converts this Observable that emits Observables into an Observable that emits the items emitted by the most recently emitted of those Observables and delays any exception until all Observables terminate.

    EXPERIMENTAL Converts this Observable that emits Observables into an Observable that emits the items emitted by the most recently emitted of those Observables and delays any exception until all Observables terminate.

    

    It subscribes to an Observable that emits Observables. Each time it observes one of these emitted Observables, the Observable returned by this method begins emitting the items emitted by that Observable. When a new Observable is emitted, it stops emitting items from the earlier-emitted Observable and begins emitting items from the new one.

    Scheduler:

    This method does not operate by default on a particular Scheduler.

    returns

    an Observable that emits the items emitted by the Observable most recently emitted by the source Observable

    Annotations

    @Experimental()

    See also

    ReactiveX operators documentation: Switch

14. def switchMap[R](f: (T) ⇒ Observable[R]): Observable[R]

    

    EXPERIMENTAL Returns a new Observable by applying a function that you supply to each item emitted by the source Observable that returns an Observable, and then emitting the items emitted by the most recently emitted of these Observables and delays any error until all Observables terminate.

    EXPERIMENTAL Returns a new Observable by applying a function that you supply to each item emitted by the source Observable that returns an Observable, and then emitting the items emitted by the most recently emitted of these Observables and delays any error until all Observables terminate.

    

    Scheduler:

    This method does not operate by default on a particular Scheduler.

    f

    a function that, when applied to an item emitted by the source Observable, returns an Observable

    returns

    an Observable that emits the items emitted by the Observable returned from applying f to the most recently emitted item emitted by the source Observable

    Annotations

    @Experimental()

    See also

    ReactiveX operators documentation: FlatMap

15. def toString(): String

    

    Definition Classes

    Any