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 java.lang.Object implements Observable.OnSubscribe<R>
Correlates the elements of two sequences based on overlapping durations.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) class
OnSubscribeJoin.ResultSink
Manage the left and right sources.
-
Field Summary
Fields Modifier and Type Field Description (package private) Observable<TLeft>
left
(package private) Func1<TLeft,Observable<TLeftDuration>>
leftDurationSelector
(package private) Func2<TLeft,TRight,R>
resultSelector
(package private) Observable<TRight>
right
(package private) Func1<TRight,Observable<TRightDuration>>
rightDurationSelector
-
Constructor Summary
Constructors Constructor Description OnSubscribeJoin(Observable<TLeft> left, Observable<TRight> right, Func1<TLeft,Observable<TLeftDuration>> leftDurationSelector, Func1<TRight,Observable<TRightDuration>> rightDurationSelector, Func2<TLeft,TRight,R> resultSelector)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
call(Subscriber<? super R> t1)
-
-
-
Field Detail
-
left
final Observable<TLeft> left
-
right
final Observable<TRight> right
-
leftDurationSelector
final Func1<TLeft,Observable<TLeftDuration>> leftDurationSelector
-
rightDurationSelector
final Func1<TRight,Observable<TRightDuration>> rightDurationSelector
-
-
Constructor Detail
-
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 Detail
-
call
public void call(Subscriber<? super R> t1)
-
-