Package rx.internal.operators
Class OnSubscribeJoin<TLeft,TRight,TLeftDuration,TRightDuration,R>
java.lang.Object
rx.internal.operators.OnSubscribeJoin<TLeft,TRight,TLeftDuration,TRightDuration,R>
- Type Parameters:
TLeft
- the left value typeTRight
- the right value typeTLeftDuration
- the left duration value typeTRightDuration
- the right duration typeR
- the result type
- All Implemented Interfaces:
Action
,Action1<Subscriber<? super R>>
,Function
,Observable.OnSubscribe<R>
public final class OnSubscribeJoin<TLeft,TRight,TLeftDuration,TRightDuration,R>
extends Object
implements Observable.OnSubscribe<R>
Correlates the elements of two sequences based on overlapping durations.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) final class
Manage the left and right sources. -
Field Summary
FieldsModifier and TypeFieldDescription(package private) final Observable
<TLeft> (package private) final Func1
<TLeft, Observable<TLeftDuration>> (package private) final Observable
<TRight> (package private) final Func1
<TRight, Observable<TRightDuration>> -
Constructor Summary
ConstructorsConstructorDescriptionOnSubscribeJoin
(Observable<TLeft> left, Observable<TRight> right, Func1<TLeft, Observable<TLeftDuration>> leftDurationSelector, Func1<TRight, Observable<TRightDuration>> rightDurationSelector, Func2<TLeft, TRight, R> resultSelector) -
Method Summary
-
Field Details
-
left
-
right
-
leftDurationSelector
-
rightDurationSelector
-
resultSelector
-
-
Constructor Details
-
OnSubscribeJoin
public OnSubscribeJoin(Observable<TLeft> left, Observable<TRight> right, Func1<TLeft, Observable<TLeftDuration>> leftDurationSelector, Func1<TRight, Observable<TRightDuration>> rightDurationSelector, Func2<TLeft, TRight, R> resultSelector)
-
-
Method Details