java.lang.Object
io.reactivex.rxjava3.internal.operators.flowable.FlowableInternalHelper.ItemDelayFunction<T,U>
- All Implemented Interfaces:
Function<T,org.reactivestreams.Publisher<T>>
- Enclosing class:
FlowableInternalHelper
static final class FlowableInternalHelper.ItemDelayFunction<T,U>
extends Object
implements Function<T,org.reactivestreams.Publisher<T>>
-
Field Summary
Fields
(package private) final Function<? super T,? extends org.reactivestreams.Publisher<U>>
-
Constructor Summary
Constructors
-
Method Summary
org.reactivestreams.Publisher<T>
Apply some calculation to the input value and return some other value.
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Field Details
-
itemDelay
final Function<? super T,? extends org.reactivestreams.Publisher<U>> itemDelay
-
Constructor Details
-
ItemDelayFunction
ItemDelayFunction(Function<? super T,? extends org.reactivestreams.Publisher<U>> itemDelay)
-
Method Details
-
apply
public org.reactivestreams.Publisher<T> apply(T v)
throws Throwable
Description copied from interface: Function
Apply some calculation to the input value and return some other value.
- Specified by:
apply
in interface Function<T,U>
- Parameters:
v
- the input value
- Returns:
- the output value
- Throws:
Throwable
- if the implementation wishes to throw any type of exception