Modifier and Type	Class and Description
pack-priv class	OnSubscribeGroupJoin.ResultManager Manages sub-observers and subscriptions.
pack-priv static class	OnSubscribeGroupJoin.WindowObservableFunc<T> The reference-counted window observable.

Modifier and Type	Field and Description
pack-priv final Observable<T1>	left
pack-priv final Func1<? super T1, ? extends Observable<D1>>	leftDuration
pack-priv final Func2<? super T1, ? super Observable<T2>, ? extends R>	resultSelector
pack-priv final Observable<T2>	right
pack-priv final Func1<? super T2, ? extends Observable<D2>>	rightDuration

Access	Constructor and Description
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)

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

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

leftDuration	back to summary
pack-priv final Func1<? super T1, ? extends Observable<D1>> leftDuration

resultSelector	back to summary
pack-priv final Func2<? super T1, ? super Observable<T2>, ? extends R> resultSelector

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

rightDuration	back to summary
pack-priv final Func1<? super T2, ? extends Observable<D2>> rightDuration

OnSubscribeGroupJoin	back to summary
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)

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

pack-priv final Class OnSubscribeGroupJoin.ResultManager

Class Inheritance

extends HashMap<Integer, Observer<T2>>
implements Subscription

java.lang.Object
java.util.AbstractMap
java.util.HashMap
rx.internal.operators.OnSubscribeGroupJoin.ResultManager

All Implemented Interfaces

Manages sub-observers and subscriptions.

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv class	OnSubscribeGroupJoin.ResultManager.LeftDurationObserver Observe left duration and apply termination.
pack-priv class	OnSubscribeGroupJoin.ResultManager.LeftObserver Observe the left source.
pack-priv class	OnSubscribeGroupJoin.ResultManager.RightDurationObserver Observe right duration and apply termination.
pack-priv class	OnSubscribeGroupJoin.ResultManager.RightObserver Observe the right source.

Field Summary

Modifier and Type	Field and Description
pack-priv final RefCountSubscription	cancel
pack-priv final CompositeSubscription	group
pack-priv boolean	leftDone Guarded by this.
pack-priv int	leftIds Guarded by this.
pack-priv boolean	rightDone Guarded by this.
pack-priv int	rightIds Guarded by this.
pack-priv final Map<Integer, T2>	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	ResultManager(Subscriber<? super R> subscriber)

Method Summary

Modifier and Type	Method and Description
pack-priv void	complete(List<Observer<T2>> list)
pack-priv void	errorAll(Throwable the exception e) Notify everyone and cleanup.
pack-priv void	errorMain(Throwable the exception e) Notify only the main subscriber and cleanup.
public void	init()
public boolean	isUnsubscribed() Implements rx.Subscription.isUnsubscribed. Indicates whether this `Subscription` is currently unsubscribed.
pack-priv Map<Integer, Observer<T2>>	leftMap()
public void	unsubscribe() Implements rx.Subscription.unsubscribe. Stops the receipt of notifications on the `Subscriber` that was registered when this Subscription was received.

Field Detail

cancel	back to summary
pack-priv final RefCountSubscription cancel

group	back to summary
pack-priv final CompositeSubscription group

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

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

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

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

rightMap	back to summary
pack-priv final Map<Integer, T2> 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

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

Method Detail

complete	back to summary
pack-priv void complete(List<Observer<T2>> list)

errorAll	back to summary
pack-priv void errorAll(Throwable e) Notify everyone and cleanup. Parameters e:Throwable the exception

errorAll

back to summary

pack-priv void errorAll(Throwable e)

Notify everyone and cleanup.

Parameters

e:Throwable: the exception

errorMain	back to summary
pack-priv void errorMain(Throwable e) Notify only the main subscriber and cleanup. Parameters e:Throwable the exception

errorMain

back to summary

pack-priv void errorMain(Throwable e)

Notify only the main subscriber and cleanup.

Parameters

e:Throwable: the exception

init	back to summary
public void init()

isUnsubscribed back to summary

isUnsubscribed	back to summary
public boolean isUnsubscribed() Implements rx.Subscription.isUnsubscribed. Doc from rx.Subscription.isUnsubscribed. Indicates whether this `Subscription` is currently unsubscribed. Returns:boolean `true` if this `Subscription` is currently unsubscribed, `false` otherwise Annotations @Override

public boolean isUnsubscribed()

Implements rx.Subscription.isUnsubscribed.

Doc from rx.Subscription.isUnsubscribed.

Indicates whether this Subscription is currently unsubscribed.

Returns:boolean

true if this Subscription is currently unsubscribed, false otherwise

Annotations

@Override

leftMap	back to summary
pack-priv Map<Integer, Observer<T2>> leftMap()

unsubscribe back to summary

unsubscribe	back to summary
public void unsubscribe() Implements rx.Subscription.unsubscribe. Doc from rx.Subscription.unsubscribe. Stops the receipt of notifications on the `Subscriber` that was registered when this Subscription was received. This allows deregistering an `Subscriber` before it has finished receiving all events (i.e. before onCompleted is called). Annotations @Override

public void unsubscribe()

Implements rx.Subscription.unsubscribe.

Doc from rx.Subscription.unsubscribe.

Stops the receipt of notifications on the Subscriber that was registered when this Subscription was received.

This allows deregistering an Subscriber before it has finished receiving all events (i.e. before onCompleted is called).

Annotations

@Override

rx.internal.operators back to summary

pack-priv final Class OnSubscribeGroupJoin.ResultManager.LeftDurationObserver

Class Inheritance

extends Subscriber<D1>

java.lang.Object
rx.Subscriber
rx.internal.operators.OnSubscribeGroupJoin.ResultManager.LeftDurationObserver

Observe left duration and apply termination.

Field Summary

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

Constructor Summary

Access	Constructor and Description
public	LeftDurationObserver(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(D1 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

LeftDurationObserver	back to summary
public LeftDurationObserver(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(D1 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:D1 the item emitted by the Observable Annotations @Override

public void onNext(D1 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:D1: the item emitted by the Observable

Annotations

@Override

rx.internal.operators back to summary

pack-priv final Class OnSubscribeGroupJoin.ResultManager.LeftObserver

Class Inheritance

extends Subscriber<T1>

java.lang.Object
rx.Subscriber
rx.internal.operators.OnSubscribeGroupJoin.ResultManager.LeftObserver

Observe the left source.

Constructor Summary

Access	Constructor and Description
pack-priv	LeftObserver()

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(T1 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

LeftObserver	back to summary
pack-priv LeftObserver()

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(T1 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:T1 the item emitted by the Observable Annotations @Override

public void onNext(T1 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:T1: the item emitted by the Observable

Annotations

@Override

rx.internal.operators back to summary

pack-priv final Class OnSubscribeGroupJoin.ResultManager.RightDurationObserver

Class Inheritance

extends Subscriber<D2>

java.lang.Object
rx.Subscriber
rx.internal.operators.OnSubscribeGroupJoin.ResultManager.RightDurationObserver

Observe right duration and apply termination.

Field Summary

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

Constructor Summary

Access	Constructor and Description
public	RightDurationObserver(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(D2 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

RightDurationObserver	back to summary
public RightDurationObserver(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(D2 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:D2: the item emitted by the Observable

Annotations

@Override

rx.internal.operators back to summary

pack-priv final Class OnSubscribeGroupJoin.ResultManager.RightObserver

Class Inheritance

extends Subscriber<T2>

java.lang.Object
rx.Subscriber
rx.internal.operators.OnSubscribeGroupJoin.ResultManager.RightObserver

Observe the right source.

Constructor Summary

Access	Constructor and Description
pack-priv	RightObserver()

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(T2 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

RightObserver	back to summary
pack-priv RightObserver()

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(T2 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:T2: the item emitted by the Observable

Annotations

@Override

rx.internal.operators back to summary

pack-priv final Class OnSubscribeGroupJoin.WindowObservableFunc<T>

Class Inheritance

extends Object
implements Observable.OnSubscribe<T>

java.lang.Object
rx.internal.operators.OnSubscribeGroupJoin.WindowObservableFunc

All Implemented Interfaces

rx.Observable.OnSubscribe, rx.functions.Action1, rx.functions.Action, rx.functions.Function

The reference-counted window observable. Subscribes to the underlying Observable by using a reference-counted subscription.

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv class	OnSubscribeGroupJoin.WindowObservableFunc.WindowSubscriber Observe activities on the window.

Field Summary

Modifier and Type	Field and Description
pack-priv final RefCountSubscription	refCount
pack-priv final Observable<T>	underlying

Constructor Summary

Access	Constructor and Description
public	WindowObservableFunc(Observable<T> underlying, RefCountSubscription refCount)

Method Summary

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

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

refCount	back to summary
pack-priv final RefCountSubscription refCount

underlying	back to summary
pack-priv final Observable<T> underlying

Constructor Detail

WindowObservableFunc	back to summary
public WindowObservableFunc(Observable<T> underlying, RefCountSubscription refCount)

Method Detail

call

back to summary

public void call(Subscriber<? super T> t1)

Implements rx.functions.Action1.call.

Annotations

@Override

rx.internal.operators back to summary

pack-priv final Class OnSubscribeGroupJoin.WindowObservableFunc.WindowSubscriber

Class Inheritance

extends Subscriber<T>

java.lang.Object
rx.Subscriber
rx.internal.operators.OnSubscribeGroupJoin.WindowObservableFunc.WindowSubscriber

Observe activities on the window.

Field Summary

Modifier and Type	Field and Description
private final Subscription	ref
pack-priv final Subscriber<? super T>	subscriber Hides rx.Subscriber.subscriber.

Constructor Summary

Access	Constructor and Description
public	WindowSubscriber(Subscriber<? super T> subscriber, Subscription ref)

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(T 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

ref	back to summary
private final Subscription ref

subscriber	back to summary
pack-priv final Subscriber<? super T> subscriber Hides rx.Subscriber.subscriber.

Constructor Detail

WindowSubscriber	back to summary
public WindowSubscriber(Subscriber<? super T> subscriber, Subscription ref)

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(T 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:T: the item emitted by the Observable

Annotations

@Override

public final Class OnSubscribeGroupJoin<T1, T2, D1, D2, R>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class OnSubscribeGroupJoin.ResultManager

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class OnSubscribeGroupJoin.ResultManager.LeftDurationObserver

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class OnSubscribeGroupJoin.ResultManager.LeftObserver

Constructor Summary

Method Summary

Constructor Detail

Method Detail

pack-priv final Class OnSubscribeGroupJoin.ResultManager.RightDurationObserver

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class OnSubscribeGroupJoin.ResultManager.RightObserver

Constructor Summary

Method Summary

Constructor Detail

Method Detail

pack-priv final Class OnSubscribeGroupJoin.WindowObservableFunc<T>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class OnSubscribeGroupJoin.WindowObservableFunc.WindowSubscriber

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail