Package io.reactivex.rxjava3.internal.operators.flowable

Class FlowableReplay.MulticastFlowable.DisposableConsumer

java.lang.Object

io.reactivex.rxjava3.internal.operators.flowable.FlowableReplay.MulticastFlowable.DisposableConsumer

All Implemented Interfaces:

Consumer<Disposable>

Enclosing class:

FlowableReplay.MulticastFlowable<R,U>

final class FlowableReplay.MulticastFlowable.DisposableConsumer
extends Object
implements Consumer<Disposable>

Field Summary

Fields

Modifier and Type	Field	Description
private final SubscriberResourceWrapper<R>	srw

Constructor Summary

Constructors

Constructor	Description
DisposableConsumer(SubscriberResourceWrapper<R> srw)

Method Summary

Modifier and Type	Method	Description
void	accept(Disposable r)	Consume the given value.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

srw

private final SubscriberResourceWrapper<R> srw

Constructor Details

DisposableConsumer

DisposableConsumer(SubscriberResourceWrapper<R> srw)

Method Details

accept

public void accept(Disposable r)

Description copied from interface: Consumer

Consume the given value.

Specified by:

accept in interface Consumer<Disposable>

Parameters:

r - the value