Class Functions.BoundedConsumer
java.lang.Object
io.reactivex.rxjava3.internal.functions.Functions.BoundedConsumer
- All Implemented Interfaces:
Consumer<org.reactivestreams.Subscription>
- Enclosing class:
Functions
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
accept
(org.reactivestreams.Subscription s) Consume the given value.
-
Field Details
-
bufferSize
final int bufferSize
-
-
Constructor Details
-
BoundedConsumer
BoundedConsumer(int bufferSize)
-
-
Method Details