Package rx.internal.operators

Class OnSubscribeGroupJoin<T1,T2,D1,D2,R>

java.lang.Object

rx.internal.operators.OnSubscribeGroupJoin<T1,T2,D1,D2,R>

Type Parameters:

T1 - the left value type

T2 - the right value type

D1 - the value type of the left duration

D2 - the value type of the right duration

R - the result value type

All Implemented Interfaces:

Action, Action1<Subscriber<? super R>>, Function, Observable.OnSubscribe<R>

public final class OnSubscribeGroupJoin<T1,T2,D1,D2,R>
extends java.lang.Object
implements Observable.OnSubscribe<R>

Correlates two sequences when they overlap and groups the results.

See Also:

MSDN: Observable.GroupJoin

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	OnSubscribeGroupJoin.ResultManager	Manages sub-observers and subscriptions.
(package private) static class	OnSubscribeGroupJoin.WindowObservableFunc<T>	The reference-counted window observable.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) Observable<T1>	left
(package private) Func1<? super T1,? extends Observable<D1>>	leftDuration
(package private) Func2<? super T1,? super Observable<T2>,? extends R>	resultSelector
(package private) Observable<T2>	right
(package private) Func1<? super T2,? extends Observable<D2>>	rightDuration

Constructor Summary

Constructors

Constructor	Description
OnSubscribeGroupJoin(Observable<T1> left, Observable<T2> right, Func1<? super T1,? extends Observable<D1>> leftDuration, Func1<? super T2,? extends Observable<D2>> rightDuration, Func2<? super T1,? super Observable<T2>,? extends R> resultSelector)

Method Summary

Modifier and Type	Method	Description
void	call(Subscriber<? super R> child)

Methods inherited from class java.lang.Object

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

Field Detail

left

final Observable<T1> left

right

final Observable<T2> right

leftDuration

final Func1<? super T1,? extends Observable<D1>> leftDuration

rightDuration

final Func1<? super T2,? extends Observable<D2>> rightDuration

resultSelector

final Func2<? super T1,? super Observable<T2>,? extends R> resultSelector

Constructor Detail

OnSubscribeGroupJoin

public OnSubscribeGroupJoin(Observable<T1> left,
                            Observable<T2> right,
                            Func1<? super T1,? extends Observable<D1>> leftDuration,
                            Func1<? super T2,? extends Observable<D2>> rightDuration,
                            Func2<? super T1,? super Observable<T2>,? extends R> resultSelector)

Method Detail

call

public void call(Subscriber<? super R> child)

Specified by:

call in interface Action1<T1>