com.github.davidmoten.rx.internal.operators

Class OrderedMerge<T>

java.lang.Object

com.github.davidmoten.rx.internal.operators.OrderedMerge<T>

Type Parameters:

T - type of observable

All Implemented Interfaces:

rx.functions.Action, rx.functions.Action1<rx.Subscriber<? super T>>, rx.functions.Function, rx.Observable.OnSubscribe<T>

public final class OrderedMerge<T>
extends Object
implements rx.Observable.OnSubscribe<T>

Author:

David Karnokd

Method Summary

Modifier and Type	Method and Description
void	call(rx.Subscriber<? super T> child)
static <U extends Comparable<? super U>> rx.Observable<U>	create(Collection<rx.Observable<U>> sources)
static <U extends Comparable<? super U>> rx.Observable<U>	create(Collection<rx.Observable<U>> sources, boolean delayErrors)
static <U> rx.Observable<U>	create(Collection<rx.Observable<U>> sources, Comparator<? super U> comparator)
static <U> rx.Observable<U>	create(Collection<rx.Observable<U>> sources, Comparator<? super U> comparator, boolean delayErrors)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

create

public static <U extends Comparable<? super U>> rx.Observable<U> create(Collection<rx.Observable<U>> sources)

create

public static <U> rx.Observable<U> create(Collection<rx.Observable<U>> sources,
                                          Comparator<? super U> comparator)

create

public static <U extends Comparable<? super U>> rx.Observable<U> create(Collection<rx.Observable<U>> sources,
                                                                        boolean delayErrors)

create

public static <U> rx.Observable<U> create(Collection<rx.Observable<U>> sources,
                                          Comparator<? super U> comparator,
                                          boolean delayErrors)

call

public void call(rx.Subscriber<? super T> child)

Specified by:

call in interface rx.functions.Action1<rx.Subscriber<? super T>>