Package io.reactivex.rxjava3.internal.functions

Class Functions.BoundedConsumer

java.lang.Object

io.reactivex.rxjava3.internal.functions.Functions.BoundedConsumer

All Implemented Interfaces:

Consumer<org.reactivestreams.Subscription>

Enclosing class:

Functions

public static class Functions.BoundedConsumer
extends Object
implements Consumer<org.reactivestreams.Subscription>

Method Summary

Modifier and Type	Method	Description
void	accept(org.reactivestreams.Subscription s)	Consume the given value.

Methods inherited from class java.lang.Object

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

Method Details

accept

public void accept(org.reactivestreams.Subscription s)

Description copied from interface: Consumer

Consume the given value.

Specified by:

accept in interface Consumer<org.reactivestreams.Subscription>

Parameters:

s - the value