Modifier and Type	Class and Description
pack-priv static class	ObservableJoin.JoinDisposable<TLeft, TRight, TLeftEnd, TRightEnd, R>

Modifier and Type	Field and Description
pack-priv final Function<? super TLeft, ? extends ObservableSource<TLeftEnd>>	leftEnd
pack-priv final ObservableSource<? extends TRight>	other
pack-priv final BiFunction<? super TLeft, ? super TRight, ? extends R>	resultSelector
pack-priv final Function<? super TRight, ? extends ObservableSource<TRightEnd>>	rightEnd

Access	Constructor and Description
public	ObservableJoin(ObservableSource<TLeft> source, ObservableSource<? extends TRight> other, Function<? super TLeft, ? extends ObservableSource<TLeftEnd>> leftEnd, Function<? super TRight, ? extends ObservableSource<TRightEnd>> rightEnd, BiFunction<? super TLeft, ? super TRight, ? extends R> resultSelector)

Modifier and Type	Method and Description
protected void	subscribeActual(Observer<? super R> the incoming Observer, never null observer) Implements abstract io.reactivex.Observable.subscribeActual. Operator implementations (both source and intermediate) should implement this method that performs the necessary business logic and handles the incoming `Observer`s.

leftEnd	back to summary
pack-priv final Function<? super TLeft, ? extends ObservableSource<TLeftEnd>> leftEnd

other	back to summary
pack-priv final ObservableSource<? extends TRight> other

resultSelector	back to summary
pack-priv final BiFunction<? super TLeft, ? super TRight, ? extends R> resultSelector

rightEnd	back to summary
pack-priv final Function<? super TRight, ? extends ObservableSource<TRightEnd>> rightEnd

ObservableJoin	back to summary
public ObservableJoin(ObservableSource<TLeft> source, ObservableSource<? extends TRight> other, Function<? super TLeft, ? extends ObservableSource<TLeftEnd>> leftEnd, Function<? super TRight, ? extends ObservableSource<TRightEnd>> rightEnd, BiFunction<? super TLeft, ? super TRight, ? extends R> resultSelector)

subscribeActual	back to summary
protected void subscribeActual(Observer<? super R> observer) Implements abstract io.reactivex.Observable.subscribeActual. Doc from io.reactivex.Observable.subscribeActual. Operator implementations (both source and intermediate) should implement this method that performs the necessary business logic and handles the incoming `Observer`s. There is no need to call any of the plugin hooks on the current `Observable` instance or the `Observer`; all hooks and basic safeguards have been applied by `subscribe(Observer)` before this method gets called. Parameters observer:Observer<? super R> the incoming Observer, never null Annotations @Override

io.reactivex.internal.operators.observable back to summary

pack-priv final Class ObservableJoin.JoinDisposable<TLeft, TRight, TLeftEnd, TRightEnd, R>

Class Inheritance

extends AtomicInteger
implements Disposable, JoinSupport

java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicInteger
io.reactivex.internal.operators.observable.ObservableJoin.JoinDisposable

All Implemented Interfaces

io.reactivex.internal.operators.observable.ObservableGroupJoin.JoinSupport, io.reactivex.disposables.Disposable

Field Summary

Modifier and Type	Field and Description
pack-priv final AtomicInteger	active
pack-priv volatile boolean	cancelled
pack-priv final CompositeDisposable	disposables
pack-priv final Observer<? super R>	downstream
pack-priv final AtomicReference<Throwable>	error
pack-priv static final Integer	LEFT_CLOSE
pack-priv static final Integer	LEFT_VALUE
pack-priv final Function<? super TLeft, ? extends ObservableSource<TLeftEnd>>	leftEnd
pack-priv int	leftIndex
pack-priv final Map<Integer, TLeft>	lefts
pack-priv final SpscLinkedArrayQueue<Object>	queue
pack-priv final BiFunction<? super TLeft, ? super TRight, ? extends R>	resultSelector
pack-priv static final Integer	RIGHT_CLOSE
pack-priv static final Integer	RIGHT_VALUE
pack-priv final Function<? super TRight, ? extends ObservableSource<TRightEnd>>	rightEnd
pack-priv int	rightIndex
pack-priv final Map<Integer, TRight>	rights
private static final long	serialVersionUID Hides java.util.concurrent.atomic.AtomicInteger.serialVersionUID.

Constructor Summary

Access	Constructor and Description
pack-priv	JoinDisposable(Observer<? super R> actual, Function<? super TLeft, ? extends ObservableSource<TLeftEnd>> leftEnd, Function<? super TRight, ? extends ObservableSource<TRightEnd>> rightEnd, BiFunction<? super TLeft, ? super TRight, ? extends R> resultSelector)

Method Summary

Modifier and Type	Method and Description
pack-priv void	cancelAll()
public void	dispose() Implements io.reactivex.disposables.Disposable.dispose. Dispose the resource, the operation should be idempotent.
pack-priv void	drain()
pack-priv void	errorAll(Observer<?> a)
pack-priv void	fail(Throwable exc, Observer<?> a, SpscLinkedArrayQueue<?> q)
public void	innerClose(boolean isLeft, ObservableGroupJoin.LeftRightEndObserver index) Implements io.reactivex.internal.operators.observable.ObservableGroupJoin.JoinSupport.innerClose.
public void	innerCloseError(Throwable ex) Implements io.reactivex.internal.operators.observable.ObservableGroupJoin.JoinSupport.innerCloseError.
public void	innerComplete(ObservableGroupJoin.LeftRightObserver sender) Implements io.reactivex.internal.operators.observable.ObservableGroupJoin.JoinSupport.innerComplete.
public void	innerError(Throwable ex) Implements io.reactivex.internal.operators.observable.ObservableGroupJoin.JoinSupport.innerError.
public void	innerValue(boolean isLeft, Object o) Implements io.reactivex.internal.operators.observable.ObservableGroupJoin.JoinSupport.innerValue.
public boolean	isDisposed() Implements io.reactivex.disposables.Disposable.isDisposed. Returns true if this resource has been disposed.

Field Detail

active	back to summary
pack-priv final AtomicInteger active

cancelled	back to summary
pack-priv volatile boolean cancelled

disposables	back to summary
pack-priv final CompositeDisposable disposables

downstream	back to summary
pack-priv final Observer<? super R> downstream

error	back to summary
pack-priv final AtomicReference<Throwable> error

LEFT_CLOSE	back to summary
pack-priv static final Integer LEFT_CLOSE

LEFT_VALUE	back to summary
pack-priv static final Integer LEFT_VALUE

leftEnd	back to summary
pack-priv final Function<? super TLeft, ? extends ObservableSource<TLeftEnd>> leftEnd

leftIndex	back to summary
pack-priv int leftIndex

lefts	back to summary
pack-priv final Map<Integer, TLeft> lefts

queue	back to summary
pack-priv final SpscLinkedArrayQueue<Object> queue

resultSelector	back to summary
pack-priv final BiFunction<? super TLeft, ? super TRight, ? extends R> resultSelector

RIGHT_CLOSE	back to summary
pack-priv static final Integer RIGHT_CLOSE

RIGHT_VALUE	back to summary
pack-priv static final Integer RIGHT_VALUE

rightEnd	back to summary
pack-priv final Function<? super TRight, ? extends ObservableSource<TRightEnd>> rightEnd

rightIndex	back to summary
pack-priv int rightIndex

rights	back to summary
pack-priv final Map<Integer, TRight> rights

serialVersionUID	back to summary
private static final long serialVersionUID Hides java.util.concurrent.atomic.AtomicInteger.serialVersionUID.

Constructor Detail

JoinDisposable	back to summary
pack-priv JoinDisposable(Observer<? super R> actual, Function<? super TLeft, ? extends ObservableSource<TLeftEnd>> leftEnd, Function<? super TRight, ? extends ObservableSource<TRightEnd>> rightEnd, BiFunction<? super TLeft, ? super TRight, ? extends R> resultSelector)

Method Detail

cancelAll	back to summary
pack-priv void cancelAll()

dispose	back to summary
public void dispose() Implements io.reactivex.disposables.Disposable.dispose. Doc from io.reactivex.disposables.Disposable.dispose. Dispose the resource, the operation should be idempotent. Annotations @Override

dispose

back to summary

public void dispose()

Implements io.reactivex.disposables.Disposable.dispose.

Doc from io.reactivex.disposables.Disposable.dispose.

Dispose the resource, the operation should be idempotent.

Annotations

@Override

drain	back to summary
pack-priv void drain()

errorAll	back to summary
pack-priv void errorAll(Observer<?> a)

fail	back to summary
pack-priv void fail(Throwable exc, Observer<?> a, SpscLinkedArrayQueue<?> q)

innerClose	back to summary
public void innerClose(boolean isLeft, ObservableGroupJoin.LeftRightEndObserver index) Implements io.reactivex.internal.operators.observable.ObservableGroupJoin.JoinSupport.innerClose. Annotations @Override

innerClose

back to summary

public void innerClose(boolean isLeft, ObservableGroupJoin.LeftRightEndObserver index)

Implements io.reactivex.internal.operators.observable.ObservableGroupJoin.JoinSupport.innerClose.

Annotations

@Override

innerCloseError	back to summary
public void innerCloseError(Throwable ex) Implements io.reactivex.internal.operators.observable.ObservableGroupJoin.JoinSupport.innerCloseError. Annotations @Override

innerCloseError

back to summary

public void innerCloseError(Throwable ex)

Implements io.reactivex.internal.operators.observable.ObservableGroupJoin.JoinSupport.innerCloseError.

Annotations

@Override

innerComplete	back to summary
public void innerComplete(ObservableGroupJoin.LeftRightObserver sender) Implements io.reactivex.internal.operators.observable.ObservableGroupJoin.JoinSupport.innerComplete. Annotations @Override

innerComplete

back to summary

public void innerComplete(ObservableGroupJoin.LeftRightObserver sender)

Implements io.reactivex.internal.operators.observable.ObservableGroupJoin.JoinSupport.innerComplete.

Annotations

@Override

innerError	back to summary
public void innerError(Throwable ex) Implements io.reactivex.internal.operators.observable.ObservableGroupJoin.JoinSupport.innerError. Annotations @Override

innerError

back to summary

public void innerError(Throwable ex)

Implements io.reactivex.internal.operators.observable.ObservableGroupJoin.JoinSupport.innerError.

Annotations

@Override

innerValue	back to summary
public void innerValue(boolean isLeft, Object o) Implements io.reactivex.internal.operators.observable.ObservableGroupJoin.JoinSupport.innerValue. Annotations @Override

innerValue

back to summary

public void innerValue(boolean isLeft, Object o)

Implements io.reactivex.internal.operators.observable.ObservableGroupJoin.JoinSupport.innerValue.

Annotations

@Override

isDisposed	back to summary
public boolean isDisposed() Implements io.reactivex.disposables.Disposable.isDisposed. Doc from io.reactivex.disposables.Disposable.isDisposed. Returns true if this resource has been disposed. Returns:boolean true if this resource has been disposed Annotations @Override

isDisposed

back to summary

public boolean isDisposed()

Implements io.reactivex.disposables.Disposable.isDisposed.

Doc from io.reactivex.disposables.Disposable.isDisposed.

Returns true if this resource has been disposed.

Returns:boolean

true if this resource has been disposed

Annotations