Class ObservableReplay.DisposeConsumer<R>

java.lang.Object
io.reactivex.rxjava3.internal.operators.observable.ObservableReplay.DisposeConsumer<R>
All Implemented Interfaces:
Consumer<Disposable>
Enclosing class:
ObservableReplay<T>

static final class ObservableReplay.DisposeConsumer<R> extends Object implements Consumer<Disposable>