Package rx.internal.util
Class InternalObservableUtils.ReplaySupplierTime<T>
java.lang.Object
rx.internal.util.InternalObservableUtils.ReplaySupplierTime<T>
- All Implemented Interfaces:
Callable<ConnectableObservable<T>>
,Func0<ConnectableObservable<T>>
,Function
- Enclosing class:
InternalObservableUtils
static final class InternalObservableUtils.ReplaySupplierTime<T>
extends Object
implements Func0<ConnectableObservable<T>>
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final int
private final Scheduler
private final Observable
<T> private final long
private final TimeUnit
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprivate
ReplaySupplierTime
(Observable<T> source, int bufferSize, long time, TimeUnit unit, Scheduler scheduler) -
Method Summary
-
Field Details
-
time
private final long time -
unit
-
scheduler
-
bufferSize
private final int bufferSize -
source
-
-
Constructor Details
-
ReplaySupplierTime
private ReplaySupplierTime(Observable<T> source, int bufferSize, long time, TimeUnit unit, Scheduler scheduler)
-
-
Method Details