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 type

TRight - the right value type

TLeftDuration - the left duration value type

TRightDuration - the right duration type

R - 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

Modifier and Type	Method	Description
void	call(Subscriber<? super R> t1)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

resultSelector

final Func2<TLeft,TRight,R> resultSelector

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)

Specified by:

call in interface Action1<TLeft>