Class FlowableInternalHelper.ItemDelayFunction<T,U>

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
    Modifier and Type
    Field
    Description
    (package private) final Function<? super T, ? extends org.reactivestreams.Publisher<U>>
    itemDelay
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    ItemDelayFunction(Function<? super T, ? extends org.reactivestreams.Publisher<U>> itemDelay)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.reactivestreams.Publisher<T>
    apply(T v)
    Apply some calculation to the input value and return some other value.

    Methods inherited from class 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