Modifier and Type	Class and Description
pack-priv static class	ObservableWindowTimed.WindowExactBoundedObserver<T>
pack-priv static class	ObservableWindowTimed.WindowExactUnboundedObserver<T>
pack-priv static class	ObservableWindowTimed.WindowSkipObserver<T>

Access	Constructor and Description
public	ObservableWindowTimed(ObservableSource<T> source, long timespan, long timeskip, TimeUnit unit, Scheduler scheduler, long maxSize, int bufferSize, boolean restartTimerOnMaxSize)

Modifier and Type	Method and Description
public void	subscribeActual(Observer<? super Observable<T>> the incoming Observer, never null t) 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.

bufferSize	back to summary
pack-priv final int bufferSize

maxSize	back to summary
pack-priv final long maxSize

restartTimerOnMaxSize	back to summary
pack-priv final boolean restartTimerOnMaxSize

scheduler	back to summary
pack-priv final Scheduler scheduler

timeskip	back to summary
pack-priv final long timeskip

timespan	back to summary
pack-priv final long timespan

unit	back to summary
pack-priv final TimeUnit unit

ObservableWindowTimed	back to summary
public ObservableWindowTimed(ObservableSource<T> source, long timespan, long timeskip, TimeUnit unit, Scheduler scheduler, long maxSize, int bufferSize, boolean restartTimerOnMaxSize)

subscribeActual	back to summary
public void subscribeActual(Observer<? super Observable<T>> t) 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 t:Observer<? super Observable<T>> the incoming Observer, never null Annotations @Override

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

pack-priv final Class ObservableWindowTimed.WindowExactBoundedObserver<T>

Class Inheritance

extends QueueDrainObserver<T, Object, Observable<T>>
implements Disposable

java.lang.Object
io.reactivex.internal.observers.QueueDrainSubscriberPad0
io.reactivex.internal.observers.QueueDrainSubscriberWip
io.reactivex.internal.observers.QueueDrainSubscriberPad2
io.reactivex.internal.observers.QueueDrainObserver
io.reactivex.internal.operators.observable.ObservableWindowTimed.WindowExactBoundedObserver

All Implemented Interfaces

io.reactivex.disposables.Disposable

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv static class	ObservableWindowTimed.WindowExactBoundedObserver.ConsumerIndexHolder

Field Summary

Modifier and Type	Field and Description
pack-priv final int	bufferSize
pack-priv long	count
pack-priv final long	maxSize
pack-priv long	producerIndex
pack-priv final boolean	restartTimerOnMaxSize
pack-priv final Scheduler	scheduler
pack-priv volatile boolean	terminated
pack-priv final SequentialDisposable	timer
pack-priv final long	timespan
pack-priv final TimeUnit	unit
pack-priv Disposable	upstream
pack-priv UnicastSubject<T>	window
pack-priv final Scheduler.Worker	worker

Inherited from io.reactivex.internal.observers.QueueDrainObserver:: cancelled done downstream error queue

Constructor Summary

Access	Constructor and Description
pack-priv	WindowExactBoundedObserver(Observer<? super Observable<T>> actual, long timespan, TimeUnit unit, Scheduler scheduler, int bufferSize, long maxSize, boolean restartTimerOnMaxSize)

Method Summary

Modifier and Type	Method and Description
public void	dispose() Implements io.reactivex.disposables.Disposable.dispose. Dispose the resource, the operation should be idempotent.
pack-priv void	disposeTimer()
pack-priv void	drainLoop()
public boolean	isDisposed() Implements io.reactivex.disposables.Disposable.isDisposed. Returns true if this resource has been disposed.
public void	onComplete() Implements io.reactivex.Observer.onComplete. Notifies the Observer that the `Observable` has finished sending push-based notifications.
public void	onError(Throwable the exception encountered by the Observable t) Implements io.reactivex.Observer.onError. Notifies the Observer that the `Observable` has experienced an error condition.
public void	onNext(T the item emitted by the Observable t) Implements io.reactivex.Observer.onNext. Provides the Observer with a new item to observe.
public void	onSubscribe(Disposable the Disposable instance whose `Disposable#dispose()` can be called anytime to cancel the connection d) Implements io.reactivex.Observer.onSubscribe. Provides the Observer with the means of cancelling (disposing) the connection (channel) with the Observable in both synchronous (from within `onNext(Object)`) and asynchronous manner.

Inherited from io.reactivex.internal.observers.QueueDrainObserver:: accept cancelled done enter error fastEnter fastPathEmit fastPathOrderedEmit leave

Field Detail

bufferSize	back to summary
pack-priv final int bufferSize

count	back to summary
pack-priv long count

maxSize	back to summary
pack-priv final long maxSize

producerIndex	back to summary
pack-priv long producerIndex

restartTimerOnMaxSize	back to summary
pack-priv final boolean restartTimerOnMaxSize

scheduler	back to summary
pack-priv final Scheduler scheduler

terminated	back to summary
pack-priv volatile boolean terminated

timer	back to summary
pack-priv final SequentialDisposable timer

timespan	back to summary
pack-priv final long timespan

unit	back to summary
pack-priv final TimeUnit unit

upstream	back to summary
pack-priv Disposable upstream

window	back to summary
pack-priv UnicastSubject<T> window

worker	back to summary
pack-priv final Scheduler.Worker worker

Constructor Detail

WindowExactBoundedObserver	back to summary
pack-priv WindowExactBoundedObserver(Observer<? super Observable<T>> actual, long timespan, TimeUnit unit, Scheduler scheduler, int bufferSize, long maxSize, boolean restartTimerOnMaxSize)

Method Detail

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

disposeTimer	back to summary
pack-priv void disposeTimer()

drainLoop	back to summary
pack-priv void drainLoop()

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

@Override

onComplete back to summary

onComplete	back to summary
public void onComplete() Implements io.reactivex.Observer.onComplete. Doc from io.reactivex.Observer.onComplete. 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 onComplete()

Implements io.reactivex.Observer.onComplete.

Doc from io.reactivex.Observer.onComplete.

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 t) Implements io.reactivex.Observer.onError. Doc from io.reactivex.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 `onComplete`. Parameters t:Throwable the exception encountered by the Observable Annotations @Override

public void onError(Throwable t)

Implements io.reactivex.Observer.onError.

Doc from io.reactivex.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 onComplete.

Parameters

t:Throwable: the exception encountered by the Observable

Annotations

@Override

onNext back to summary

onNext	back to summary
public void onNext(T t) Implements io.reactivex.Observer.onNext. Doc from io.reactivex.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 `onComplete` or `onError`. Parameters t:T the item emitted by the Observable Annotations @Override

public void onNext(T t)

Implements io.reactivex.Observer.onNext.

Doc from io.reactivex.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 onComplete or onError.

Parameters

t:T: the item emitted by the Observable

Annotations

@Override

onSubscribe back to summary

onSubscribe	back to summary
public void onSubscribe(Disposable d) Implements io.reactivex.Observer.onSubscribe. Doc from io.reactivex.Observer.onSubscribe. Provides the Observer with the means of cancelling (disposing) the connection (channel) with the Observable in both synchronous (from within `onNext(Object)`) and asynchronous manner. Parameters d:Disposable the Disposable instance whose `Disposable#dispose()` can be called anytime to cancel the connection Annotations @Override

public void onSubscribe(Disposable d)

Implements io.reactivex.Observer.onSubscribe.

Doc from io.reactivex.Observer.onSubscribe.

Provides the Observer with the means of cancelling (disposing) the connection (channel) with the Observable in both synchronous (from within onNext(Object)) and asynchronous manner.

Parameters

d:Disposable: the Disposable instance whose Disposable#dispose() can be called anytime to cancel the connection

Annotations

@Override

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

pack-priv final Class ObservableWindowTimed.WindowExactBoundedObserver.ConsumerIndexHolder

Class Inheritance

extends Object
implements Runnable

java.lang.Object
io.reactivex.internal.operators.observable.ObservableWindowTimed.WindowExactBoundedObserver.ConsumerIndexHolder

All Implemented Interfaces

java.lang.Runnable

Field Summary

Modifier and Type	Field and Description
pack-priv final long	index
pack-priv final ObservableWindowTimed.WindowExactBoundedObserver<?>	parent

Constructor Summary

Access	Constructor and Description
pack-priv	ConsumerIndexHolder(long index, ObservableWindowTimed.WindowExactBoundedObserver<?> parent)

Method Summary

Modifier and Type	Method and Description
public void	run() Implements java.lang.Runnable.run. Runs this operation.

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

Field Detail

index	back to summary
pack-priv final long index

parent	back to summary
pack-priv final ObservableWindowTimed.WindowExactBoundedObserver<?> parent

Constructor Detail

ConsumerIndexHolder	back to summary
pack-priv ConsumerIndexHolder(long index, ObservableWindowTimed.WindowExactBoundedObserver<?> parent)

Method Detail

run	back to summary
public void run() Implements java.lang.Runnable.run. Doc from java.lang.Runnable.run. Runs this operation. Annotations @Override

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

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

pack-priv final Class ObservableWindowTimed.WindowExactUnboundedObserver<T>

Class Inheritance

extends QueueDrainObserver<T, Object, Observable<T>>
implements Observer<T>, Disposable, Runnable

java.lang.Object
io.reactivex.internal.observers.QueueDrainSubscriberPad0
io.reactivex.internal.observers.QueueDrainSubscriberWip
io.reactivex.internal.observers.QueueDrainSubscriberPad2
io.reactivex.internal.observers.QueueDrainObserver
io.reactivex.internal.operators.observable.ObservableWindowTimed.WindowExactUnboundedObserver

All Implemented Interfaces

java.lang.Runnable, io.reactivex.disposables.Disposable, io.reactivex.Observer

Field Summary

Modifier and Type	Field and Description
pack-priv final int	bufferSize
pack-priv static final Object	NEXT
pack-priv final Scheduler	scheduler
pack-priv volatile boolean	terminated
pack-priv final SequentialDisposable	timer
pack-priv final long	timespan
pack-priv final TimeUnit	unit
pack-priv Disposable	upstream
pack-priv UnicastSubject<T>	window

Inherited from io.reactivex.internal.observers.QueueDrainObserver:: cancelled done downstream error queue

Constructor Summary

Access	Constructor and Description
pack-priv	WindowExactUnboundedObserver(Observer<? super Observable<T>> actual, long timespan, TimeUnit unit, Scheduler scheduler, int bufferSize)

Method Summary

Modifier and Type	Method and Description
public void	dispose() Implements io.reactivex.disposables.Disposable.dispose. Dispose the resource, the operation should be idempotent.
pack-priv void	drainLoop()
public boolean	isDisposed() Implements io.reactivex.disposables.Disposable.isDisposed. Returns true if this resource has been disposed.
public void	onComplete() Implements io.reactivex.Observer.onComplete. Notifies the Observer that the `Observable` has finished sending push-based notifications.
public void	onError(Throwable the exception encountered by the Observable t) Implements io.reactivex.Observer.onError. Notifies the Observer that the `Observable` has experienced an error condition.
public void	onNext(T the item emitted by the Observable t) Implements io.reactivex.Observer.onNext. Provides the Observer with a new item to observe.
public void	onSubscribe(Disposable the Disposable instance whose `Disposable#dispose()` can be called anytime to cancel the connection d) Implements io.reactivex.Observer.onSubscribe. Provides the Observer with the means of cancelling (disposing) the connection (channel) with the Observable in both synchronous (from within `onNext(Object)`) and asynchronous manner.
public void	run() Implements java.lang.Runnable.run. Runs this operation.

Inherited from io.reactivex.internal.observers.QueueDrainObserver:: accept cancelled done enter error fastEnter fastPathEmit fastPathOrderedEmit leave

Field Detail

bufferSize	back to summary
pack-priv final int bufferSize

NEXT	back to summary
pack-priv static final Object NEXT

scheduler	back to summary
pack-priv final Scheduler scheduler

terminated	back to summary
pack-priv volatile boolean terminated

timer	back to summary
pack-priv final SequentialDisposable timer

timespan	back to summary
pack-priv final long timespan

unit	back to summary
pack-priv final TimeUnit unit

upstream	back to summary
pack-priv Disposable upstream

window	back to summary
pack-priv UnicastSubject<T> window

Constructor Detail

WindowExactUnboundedObserver	back to summary
pack-priv WindowExactUnboundedObserver(Observer<? super Observable<T>> actual, long timespan, TimeUnit unit, Scheduler scheduler, int bufferSize)

Method Detail

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

drainLoop	back to summary
pack-priv void drainLoop()

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

onComplete back to summary

public void onComplete()

Implements io.reactivex.Observer.onComplete.

Doc from io.reactivex.Observer.onComplete.

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 t)

Implements io.reactivex.Observer.onError.

Doc from io.reactivex.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 onComplete.

Parameters

t:Throwable: the exception encountered by the Observable

Annotations

@Override

onNext back to summary

public void onNext(T t)

Implements io.reactivex.Observer.onNext.

Doc from io.reactivex.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 onComplete or onError.

Parameters

t:T: the item emitted by the Observable

Annotations

@Override

onSubscribe back to summary

public void onSubscribe(Disposable d)

Implements io.reactivex.Observer.onSubscribe.

Doc from io.reactivex.Observer.onSubscribe.

Provides the Observer with the means of cancelling (disposing) the connection (channel) with the Observable in both synchronous (from within onNext(Object)) and asynchronous manner.

Parameters

d:Disposable: the Disposable instance whose Disposable#dispose() can be called anytime to cancel the connection

Annotations

@Override

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

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

pack-priv final Class ObservableWindowTimed.WindowSkipObserver<T>

Class Inheritance

extends QueueDrainObserver<T, Object, Observable<T>>
implements Disposable, Runnable

java.lang.Object
io.reactivex.internal.observers.QueueDrainSubscriberPad0
io.reactivex.internal.observers.QueueDrainSubscriberWip
io.reactivex.internal.observers.QueueDrainSubscriberPad2
io.reactivex.internal.observers.QueueDrainObserver
io.reactivex.internal.operators.observable.ObservableWindowTimed.WindowSkipObserver

All Implemented Interfaces

java.lang.Runnable, io.reactivex.disposables.Disposable

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv class	ObservableWindowTimed.WindowSkipObserver.CompletionTask
pack-priv static class	ObservableWindowTimed.WindowSkipObserver.SubjectWork<T>

Field Summary

Modifier and Type	Field and Description
pack-priv final int	bufferSize
pack-priv volatile boolean	terminated
pack-priv final long	timeskip
pack-priv final long	timespan
pack-priv final TimeUnit	unit
pack-priv Disposable	upstream
pack-priv final List<UnicastSubject<T>>	windows
pack-priv final Scheduler.Worker	worker

Inherited from io.reactivex.internal.observers.QueueDrainObserver:: cancelled done downstream error queue

Constructor Summary

Access	Constructor and Description
pack-priv	WindowSkipObserver(Observer<? super Observable<T>> actual, long timespan, long timeskip, TimeUnit unit, Scheduler.Worker worker, int bufferSize)

Method Summary

Modifier and Type	Method and Description
pack-priv void	complete(UnicastSubject<T> w)
public void	dispose() Implements io.reactivex.disposables.Disposable.dispose. Dispose the resource, the operation should be idempotent.
pack-priv void	drainLoop()
public boolean	isDisposed() Implements io.reactivex.disposables.Disposable.isDisposed. Returns true if this resource has been disposed.
public void	onComplete() Implements io.reactivex.Observer.onComplete. Notifies the Observer that the `Observable` has finished sending push-based notifications.
public void	onError(Throwable the exception encountered by the Observable t) Implements io.reactivex.Observer.onError. Notifies the Observer that the `Observable` has experienced an error condition.
public void	onNext(T the item emitted by the Observable t) Implements io.reactivex.Observer.onNext. Provides the Observer with a new item to observe.
public void	onSubscribe(Disposable the Disposable instance whose `Disposable#dispose()` can be called anytime to cancel the connection d) Implements io.reactivex.Observer.onSubscribe. Provides the Observer with the means of cancelling (disposing) the connection (channel) with the Observable in both synchronous (from within `onNext(Object)`) and asynchronous manner.
public void	run() Implements java.lang.Runnable.run. Runs this operation.

Inherited from io.reactivex.internal.observers.QueueDrainObserver:: accept cancelled done enter error fastEnter fastPathEmit fastPathOrderedEmit leave

Field Detail

bufferSize	back to summary
pack-priv final int bufferSize

terminated	back to summary
pack-priv volatile boolean terminated

timeskip	back to summary
pack-priv final long timeskip

timespan	back to summary
pack-priv final long timespan

unit	back to summary
pack-priv final TimeUnit unit

upstream	back to summary
pack-priv Disposable upstream

windows	back to summary
pack-priv final List<UnicastSubject<T>> windows

worker	back to summary
pack-priv final Scheduler.Worker worker

Constructor Detail

WindowSkipObserver	back to summary
pack-priv WindowSkipObserver(Observer<? super Observable<T>> actual, long timespan, long timeskip, TimeUnit unit, Scheduler.Worker worker, int bufferSize)

Method Detail

complete	back to summary
pack-priv void complete(UnicastSubject<T> w)

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

drainLoop	back to summary
pack-priv void drainLoop() Annotations @SuppressWarnings:unchecked

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

onComplete back to summary

public void onComplete()

Implements io.reactivex.Observer.onComplete.

Doc from io.reactivex.Observer.onComplete.

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 t)

Implements io.reactivex.Observer.onError.

Doc from io.reactivex.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 onComplete.

Parameters

t:Throwable: the exception encountered by the Observable

Annotations

@Override

onNext back to summary

public void onNext(T t)

Implements io.reactivex.Observer.onNext.

Doc from io.reactivex.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 onComplete or onError.

Parameters

t:T: the item emitted by the Observable

Annotations

@Override

onSubscribe back to summary

public void onSubscribe(Disposable d)

Implements io.reactivex.Observer.onSubscribe.

Doc from io.reactivex.Observer.onSubscribe.

Provides the Observer with the means of cancelling (disposing) the connection (channel) with the Observable in both synchronous (from within onNext(Object)) and asynchronous manner.

Parameters

d:Disposable: the Disposable instance whose Disposable#dispose() can be called anytime to cancel the connection

Annotations

@Override

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

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

pack-priv final Class ObservableWindowTimed.WindowSkipObserver.CompletionTask

Class Inheritance

extends Object
implements Runnable

java.lang.Object
io.reactivex.internal.operators.observable.ObservableWindowTimed.WindowSkipObserver.CompletionTask

All Implemented Interfaces

java.lang.Runnable

Field Summary

Modifier and Type	Field and Description
private final UnicastSubject<T>	w

Constructor Summary

Access	Constructor and Description
pack-priv	CompletionTask(UnicastSubject<T> w)

Method Summary

Modifier and Type	Method and Description
public void	run() Implements java.lang.Runnable.run. Runs this operation.

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

Field Detail

w	back to summary
private final UnicastSubject<T> w

Constructor Detail

CompletionTask	back to summary
pack-priv CompletionTask(UnicastSubject<T> w)

Method Detail

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

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

pack-priv final Class ObservableWindowTimed.WindowSkipObserver.SubjectWork<T>

Class Inheritance

extends Object

java.lang.Object
io.reactivex.internal.operators.observable.ObservableWindowTimed.WindowSkipObserver.SubjectWork

Field Summary

Modifier and Type	Field and Description
pack-priv final boolean	open
pack-priv final UnicastSubject<T>	w

Constructor Summary

Access	Constructor and Description
pack-priv	SubjectWork(UnicastSubject<T> w, boolean open)

Method Summary

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

Field Detail

open	back to summary
pack-priv final boolean open

w	back to summary
pack-priv final UnicastSubject<T> w

Constructor Detail

SubjectWork	back to summary
pack-priv SubjectWork(UnicastSubject<T> w, boolean open)

public final Class ObservableWindowTimed<T>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class ObservableWindowTimed.WindowExactBoundedObserver<T>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class ObservableWindowTimed.WindowExactBoundedObserver.ConsumerIndexHolder

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class ObservableWindowTimed.WindowExactUnboundedObserver<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class ObservableWindowTimed.WindowSkipObserver<T>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class ObservableWindowTimed.WindowSkipObserver.CompletionTask

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class ObservableWindowTimed.WindowSkipObserver.SubjectWork<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail