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 typeT2
- the right value typeD1
- the value type of the left durationD2
- the value type of the right durationR
- 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 Object
implements Observable.OnSubscribe<R>
Correlates two sequences when they overlap and groups the results.
- See Also:
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) final class
Manages sub-observers and subscriptions.(package private) static final class
The reference-counted window observable. -
Field Summary
FieldsModifier and TypeFieldDescription(package private) final Observable
<T1> (package private) final Func1
<? super T1, ? extends Observable<D1>> (package private) final Func2
<? super T1, ? super Observable<T2>, ? extends R> (package private) final Observable
<T2> (package private) final Func1
<? super T2, ? extends Observable<D2>> -
Constructor Summary
ConstructorsConstructorDescriptionOnSubscribeGroupJoin
(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
-
Field Details
-
left
-
right
-
leftDuration
-
rightDuration
-
resultSelector
-
-
Constructor Details
-
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 Details