Class ObservableReplay.ReplaySource<T>
java.lang.Object
io.reactivex.rxjava3.internal.operators.observable.ObservableReplay.ReplaySource<T>
- All Implemented Interfaces:
ObservableSource<T>
- Enclosing class:
ObservableReplay<T>
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final ObservableReplay.BufferSupplier
<T> private final AtomicReference
<ObservableReplay.ReplayObserver<T>> -
Constructor Summary
ConstructorsConstructorDescriptionReplaySource
(AtomicReference<ObservableReplay.ReplayObserver<T>> curr, ObservableReplay.BufferSupplier<T> bufferFactory) -
Method Summary
Modifier and TypeMethodDescriptionvoid
Subscribes the givenObserver
to thisObservableSource
instance.
-
Field Details
-
curr
-
bufferFactory
-
-
Constructor Details
-
ReplaySource
ReplaySource(AtomicReference<ObservableReplay.ReplayObserver<T>> curr, ObservableReplay.BufferSupplier<T> bufferFactory)
-
-
Method Details
-
subscribe
Description copied from interface:ObservableSource
Subscribes the givenObserver
to thisObservableSource
instance.- Specified by:
subscribe
in interfaceObservableSource<T>
- Parameters:
child
- theObserver
, notnull
-