Class FlowableInternalHelper.FlatMapWithCombinerOuter<T,R,U>

java.lang.Object
io.reactivex.rxjava3.internal.operators.flowable.FlowableInternalHelper.FlatMapWithCombinerOuter<T,R,U>
All Implemented Interfaces:
Function<T, org.reactivestreams.Publisher<R>>
Enclosing class:
FlowableInternalHelper
static final class FlowableInternalHelper.FlatMapWithCombinerOuter<T,R,U> extends Object implements Function<T, org.reactivestreams.Publisher<R>>

  • Field Details

    • combiner

      private final BiFunction<? super T, ? super U, ? extends R> combiner

    • mapper

      private final Function<? super T, ? extends org.reactivestreams.Publisher<? extends U>> mapper

  • Constructor Details

    • FlatMapWithCombinerOuter

      FlatMapWithCombinerOuter(BiFunction<? super T, ? super U, ? extends R> combiner, Function<? super T, ? extends org.reactivestreams.Publisher<? extends U>> mapper)

  • Method Details

    • apply

      public org.reactivestreams.Publisher<R> apply(T t) 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,R>
      Parameters:
      t - the input value
      Returns:
      the output value
      Throws:
      Throwable - if the implementation wishes to throw any type of exception