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
public final class OnSubscribeGroupJoin<T1,T2 extends Object,D1 ,D2 ,R> implements Observable .OnSubscribe <R>
| Modifier and Type | Field and Description |
|---|---|
protected Observable |
left
|
protected Func1 |
leftDuration
|
protected Func2 |
resultSelector
|
protected Observable |
right
|
protected Func1 |
rightDuration
|
| Constructor and Description |
|---|
OnSubscribeGroupJoin(Observable
|
protected final Observable<T1> left
protected final Observable<T2> right
protected final Func1<? super T1 ,? extends Observable <D1>> leftDuration
protected final Func1<? super T2 ,? extends Observable <D2>> rightDuration
protected final Func2<? super T1 ,? super Observable <T2> ,? extends R> resultSelector
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)
public void call(Subscriber<? super R> child)