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 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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
call(Subscriber<? super R> child)
-
-
-
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)
-
-