Modifier and Type	Class and Description
pack-priv class	OnSubscribeJoin.ResultSink Manage the left and right sources.

Modifier and Type	Field and Description
pack-priv final Observable<TLeft>	left
pack-priv final Func1<TLeft, Observable<TLeftDuration>>	leftDurationSelector
pack-priv final Func2<TLeft, TRight, R>	resultSelector
pack-priv final Observable<TRight>	right
pack-priv final Func1<TRight, Observable<TRightDuration>>	rightDurationSelector

Access	Constructor and Description
public	OnSubscribeJoin(Observable<TLeft> left, Observable<TRight> right, Func1<TLeft, Observable<TLeftDuration>> leftDurationSelector, Func1<TRight, Observable<TRightDuration>> rightDurationSelector, Func2<TLeft, TRight, R> resultSelector)

Modifier and Type	Method and Description
public void	call(Subscriber<? super R> t1) Implements rx.functions.Action1.call.

left	back to summary
pack-priv final Observable<TLeft> left

leftDurationSelector	back to summary
pack-priv final Func1<TLeft, Observable<TLeftDuration>> leftDurationSelector

resultSelector	back to summary
pack-priv final Func2<TLeft, TRight, R> resultSelector

right	back to summary
pack-priv final Observable<TRight> right

rightDurationSelector	back to summary
pack-priv final Func1<TRight, Observable<TRightDuration>> rightDurationSelector

OnSubscribeJoin	back to summary
public OnSubscribeJoin(Observable<TLeft> left, Observable<TRight> right, Func1<TLeft, Observable<TLeftDuration>> leftDurationSelector, Func1<TRight, Observable<TRightDuration>> rightDurationSelector, Func2<TLeft, TRight, R> resultSelector)

call	back to summary
public void call(Subscriber<? super R> t1) Implements rx.functions.Action1.call. Annotations @Override

pack-priv final Class OnSubscribeJoin.ResultSink

Class Inheritance

java.lang.Object
java.util.AbstractMap
java.util.HashMap
rx.internal.operators.OnSubscribeJoin.ResultSink

Manage the left and right sources.

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv class	OnSubscribeJoin.ResultSink.LeftSubscriber Observes the left values.
pack-priv class	OnSubscribeJoin.ResultSink.RightSubscriber Observes the right values.

Field Summary

Modifier and Type	Field and Description
pack-priv final CompositeSubscription	group
pack-priv boolean	leftDone Guarded by this.
pack-priv int	leftId Guarded by this.
pack-priv boolean	rightDone Guarded by this.
pack-priv int	rightId Guarded by this.
pack-priv final Map<Integer, TRight>	rightMap Guarded by this.
private static final long	serialVersionUID Hides java.util.HashMap.serialVersionUID.
pack-priv final Subscriber<? super R>	subscriber

Constructor Summary

Access	Constructor and Description
public	ResultSink(Subscriber<? super R> subscriber)

Method Summary

Modifier and Type	Method and Description
pack-priv HashMap<Integer, TLeft>	leftMap()
public void	run()

Field Detail

group	back to summary
pack-priv final CompositeSubscription group

leftDone	back to summary
pack-priv boolean leftDone Guarded by this.

leftId	back to summary
pack-priv int leftId Guarded by this.

rightDone	back to summary
pack-priv boolean rightDone Guarded by this.

rightId	back to summary
pack-priv int rightId Guarded by this.

rightMap	back to summary
pack-priv final Map<Integer, TRight> rightMap Guarded by this.

serialVersionUID	back to summary
private static final long serialVersionUID Hides java.util.HashMap.serialVersionUID.

subscriber	back to summary
pack-priv final Subscriber<? super R> subscriber

Constructor Detail

ResultSink	back to summary
public ResultSink(Subscriber<? super R> subscriber)

Method Detail

leftMap	back to summary
pack-priv HashMap<Integer, TLeft> leftMap()

run	back to summary
public void run()

rx.internal.operators back to summary

pack-priv final Class OnSubscribeJoin.ResultSink.LeftSubscriber

Class Inheritance

extends Subscriber<TLeft>

java.lang.Object
rx.Subscriber
rx.internal.operators.OnSubscribeJoin.ResultSink.LeftSubscriber

Observes the left values.

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv class	OnSubscribeJoin.ResultSink.LeftSubscriber.LeftDurationSubscriber Observes the left duration.

Constructor Summary

Access	Constructor and Description
pack-priv	LeftSubscriber()

Method Summary

Modifier and Type	Method and Description
protected void	expire(int id, Subscription resource)
public void	onCompleted() Implements rx.Observer.onCompleted. Notifies the Observer that the `Observable` has finished sending push-based notifications.
public void	onError(Throwable the exception encountered by the Observable e) Implements rx.Observer.onError. Notifies the Observer that the `Observable` has experienced an error condition.
public void	onNext(TLeft the item emitted by the Observable args) Implements rx.Observer.onNext. Provides the Observer with a new item to observe.

Inherited from rx.Subscriber:: add isUnsubscribed onStart request setProducer unsubscribe

Constructor Detail

LeftSubscriber	back to summary
pack-priv LeftSubscriber()

Method Detail

expire	back to summary
protected void expire(int id, Subscription resource)

onCompleted back to summary

onCompleted	back to summary
public void onCompleted() Implements rx.Observer.onCompleted. Doc from rx.Observer.onCompleted. Notifies the Observer that the `Observable` has finished sending push-based notifications. The `Observable` will not call this method if it calls `onError`. Annotations @Override

public void onCompleted()

Implements rx.Observer.onCompleted.

Doc from rx.Observer.onCompleted.

Notifies the Observer that the Observable has finished sending push-based notifications.

The Observable will not call this method if it calls onError.

Annotations

@Override

onError back to summary

onError	back to summary
public void onError(Throwable e) Implements rx.Observer.onError. Doc from rx.Observer.onError. Notifies the Observer that the `Observable` has experienced an error condition. If the `Observable` calls this method, it will not thereafter call `onNext` or `onCompleted`. Parameters e:Throwable the exception encountered by the Observable Annotations @Override

public void onError(Throwable e)

Implements rx.Observer.onError.

Doc from rx.Observer.onError.

Notifies the Observer that the Observable has experienced an error condition.

If the Observable calls this method, it will not thereafter call onNext or onCompleted.

Parameters

e:Throwable: the exception encountered by the Observable

Annotations

@Override

onNext back to summary

onNext	back to summary
public void onNext(TLeft args) Implements rx.Observer.onNext. Doc from rx.Observer.onNext. Provides the Observer with a new item to observe. The `Observable` may call this method 0 or more times. The `Observable` will not call this method again after it calls either `onCompleted` or `onError`. Parameters args:TLeft the item emitted by the Observable Annotations @Override

public void onNext(TLeft args)

Implements rx.Observer.onNext.

Doc from rx.Observer.onNext.

Provides the Observer with a new item to observe.

The Observable may call this method 0 or more times.

The Observable will not call this method again after it calls either onCompleted or onError.

Parameters

args:TLeft: the item emitted by the Observable

Annotations

@Override

rx.internal.operators back to summary

pack-priv final Class OnSubscribeJoin.ResultSink.LeftSubscriber.LeftDurationSubscriber

Class Inheritance

extends Subscriber<TLeftDuration>

java.lang.Object
rx.Subscriber
rx.internal.operators.OnSubscribeJoin.ResultSink.LeftSubscriber.LeftDurationSubscriber

Observes the left duration.

Field Summary

Modifier and Type	Field and Description
pack-priv final int	id
pack-priv boolean	once

Constructor Summary

Access	Constructor and Description
public	LeftDurationSubscriber(int id)

Method Summary

Modifier and Type	Method and Description
public void	onCompleted() Implements rx.Observer.onCompleted. Notifies the Observer that the `Observable` has finished sending push-based notifications.
public void	onError(Throwable the exception encountered by the Observable e) Implements rx.Observer.onError. Notifies the Observer that the `Observable` has experienced an error condition.
public void	onNext(TLeftDuration the item emitted by the Observable args) Implements rx.Observer.onNext. Provides the Observer with a new item to observe.

Inherited from rx.Subscriber:: add isUnsubscribed onStart request setProducer unsubscribe

Field Detail

id	back to summary
pack-priv final int id

once	back to summary
pack-priv boolean once

Constructor Detail

LeftDurationSubscriber	back to summary
public LeftDurationSubscriber(int id)

Method Detail

onCompleted back to summary

onCompleted	back to summary
public void onCompleted() Implements rx.Observer.onCompleted. Doc from rx.Observer.onCompleted. Notifies the Observer that the `Observable` has finished sending push-based notifications. The `Observable` will not call this method if it calls `onError`. Annotations @Override

public void onCompleted()

Implements rx.Observer.onCompleted.

Doc from rx.Observer.onCompleted.

Notifies the Observer that the Observable has finished sending push-based notifications.

The Observable will not call this method if it calls onError.

Annotations

@Override

onError back to summary

onError	back to summary
public void onError(Throwable e) Implements rx.Observer.onError. Doc from rx.Observer.onError. Notifies the Observer that the `Observable` has experienced an error condition. If the `Observable` calls this method, it will not thereafter call `onNext` or `onCompleted`. Parameters e:Throwable the exception encountered by the Observable Annotations @Override

public void onError(Throwable e)

Implements rx.Observer.onError.

Doc from rx.Observer.onError.

Notifies the Observer that the Observable has experienced an error condition.

If the Observable calls this method, it will not thereafter call onNext or onCompleted.

Parameters

e:Throwable: the exception encountered by the Observable

Annotations

@Override

onNext back to summary

onNext	back to summary
public void onNext(TLeftDuration args) Implements rx.Observer.onNext. Doc from rx.Observer.onNext. Provides the Observer with a new item to observe. The `Observable` may call this method 0 or more times. The `Observable` will not call this method again after it calls either `onCompleted` or `onError`. Parameters args:TLeftDuration the item emitted by the Observable Annotations @Override

public void onNext(TLeftDuration args)

Implements rx.Observer.onNext.

Doc from rx.Observer.onNext.

Provides the Observer with a new item to observe.

The Observable may call this method 0 or more times.

The Observable will not call this method again after it calls either onCompleted or onError.

Parameters

args:TLeftDuration: the item emitted by the Observable

Annotations

@Override

rx.internal.operators back to summary

pack-priv final Class OnSubscribeJoin.ResultSink.RightSubscriber

Class Inheritance

extends Subscriber<TRight>

java.lang.Object
rx.Subscriber
rx.internal.operators.OnSubscribeJoin.ResultSink.RightSubscriber

Observes the right values.

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv class	OnSubscribeJoin.ResultSink.RightSubscriber.RightDurationSubscriber Observe the right duration.

Constructor Summary

Access	Constructor and Description
pack-priv	RightSubscriber()

Method Summary

Modifier and Type	Method and Description
pack-priv void	expire(int id, Subscription resource)
public void	onCompleted() Implements rx.Observer.onCompleted. Notifies the Observer that the `Observable` has finished sending push-based notifications.
public void	onError(Throwable the exception encountered by the Observable e) Implements rx.Observer.onError. Notifies the Observer that the `Observable` has experienced an error condition.
public void	onNext(TRight the item emitted by the Observable args) Implements rx.Observer.onNext. Provides the Observer with a new item to observe.

Inherited from rx.Subscriber:: add isUnsubscribed onStart request setProducer unsubscribe

Constructor Detail

RightSubscriber	back to summary
pack-priv RightSubscriber()

Method Detail

expire	back to summary
pack-priv void expire(int id, Subscription resource)

onCompleted back to summary

onCompleted	back to summary
public void onCompleted() Implements rx.Observer.onCompleted. Doc from rx.Observer.onCompleted. Notifies the Observer that the `Observable` has finished sending push-based notifications. The `Observable` will not call this method if it calls `onError`. Annotations @Override

public void onCompleted()

Implements rx.Observer.onCompleted.

Doc from rx.Observer.onCompleted.

Notifies the Observer that the Observable has finished sending push-based notifications.

The Observable will not call this method if it calls onError.

Annotations

@Override

onError back to summary

onError	back to summary
public void onError(Throwable e) Implements rx.Observer.onError. Doc from rx.Observer.onError. Notifies the Observer that the `Observable` has experienced an error condition. If the `Observable` calls this method, it will not thereafter call `onNext` or `onCompleted`. Parameters e:Throwable the exception encountered by the Observable Annotations @Override

public void onError(Throwable e)

Implements rx.Observer.onError.

Doc from rx.Observer.onError.

Notifies the Observer that the Observable has experienced an error condition.

If the Observable calls this method, it will not thereafter call onNext or onCompleted.

Parameters

e:Throwable: the exception encountered by the Observable

Annotations

@Override

onNext back to summary

public void onNext(TRight args)

Implements rx.Observer.onNext.

Doc from rx.Observer.onNext.

Provides the Observer with a new item to observe.

The Observable may call this method 0 or more times.

The Observable will not call this method again after it calls either onCompleted or onError.

Parameters

args:TRight: the item emitted by the Observable

Annotations

@Override

rx.internal.operators back to summary

pack-priv final Class OnSubscribeJoin.ResultSink.RightSubscriber.RightDurationSubscriber

Class Inheritance

extends Subscriber<TRightDuration>

java.lang.Object
rx.Subscriber
rx.internal.operators.OnSubscribeJoin.ResultSink.RightSubscriber.RightDurationSubscriber

Observe the right duration.

Field Summary

Modifier and Type	Field and Description
pack-priv final int	id
pack-priv boolean	once

Constructor Summary

Access	Constructor and Description
public	RightDurationSubscriber(int id)

Method Summary

Modifier and Type	Method and Description
public void	onCompleted() Implements rx.Observer.onCompleted. Notifies the Observer that the `Observable` has finished sending push-based notifications.
public void	onError(Throwable the exception encountered by the Observable e) Implements rx.Observer.onError. Notifies the Observer that the `Observable` has experienced an error condition.
public void	onNext(TRightDuration the item emitted by the Observable args) Implements rx.Observer.onNext. Provides the Observer with a new item to observe.

Inherited from rx.Subscriber:: add isUnsubscribed onStart request setProducer unsubscribe

Field Detail

id	back to summary
pack-priv final int id

once	back to summary
pack-priv boolean once

Constructor Detail

RightDurationSubscriber	back to summary
public RightDurationSubscriber(int id)

Method Detail

onCompleted back to summary

public void onCompleted()

Implements rx.Observer.onCompleted.

Doc from rx.Observer.onCompleted.

Notifies the Observer that the Observable has finished sending push-based notifications.

The Observable will not call this method if it calls onError.

Annotations

@Override

onError back to summary

public void onError(Throwable e)

Implements rx.Observer.onError.

Doc from rx.Observer.onError.

Notifies the Observer that the Observable has experienced an error condition.

If the Observable calls this method, it will not thereafter call onNext or onCompleted.

Parameters

e:Throwable: the exception encountered by the Observable

Annotations

@Override

onNext back to summary

public void onNext(TRightDuration args)

Implements rx.Observer.onNext.

Doc from rx.Observer.onNext.

Provides the Observer with a new item to observe.

The Observable may call this method 0 or more times.

The Observable will not call this method again after it calls either onCompleted or onError.

Parameters

args:TRightDuration: the item emitted by the Observable

Annotations

@Override

public final Class OnSubscribeJoin<TLeft, TRight, TLeftDuration, TRightDuration, R>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class OnSubscribeJoin.ResultSink

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class OnSubscribeJoin.ResultSink.LeftSubscriber

Nested and Inner Type Summary

Constructor Summary

Method Summary

Constructor Detail

Method Detail

pack-priv final Class OnSubscribeJoin.ResultSink.LeftSubscriber.LeftDurationSubscriber

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class OnSubscribeJoin.ResultSink.RightSubscriber

Nested and Inner Type Summary

Constructor Summary

Method Summary

Constructor Detail

Method Detail

pack-priv final Class OnSubscribeJoin.ResultSink.RightSubscriber.RightDurationSubscriber

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail