Class ObservableInternalHelper.FlatMapWithCombinerInner<U,R,T>

java.lang.Object
io.reactivex.rxjava3.internal.operators.observable.ObservableInternalHelper.FlatMapWithCombinerInner<U,R,T>
All Implemented Interfaces:
Function<U,R>
Enclosing class:
ObservableInternalHelper

static final class ObservableInternalHelper.FlatMapWithCombinerInner<U,R,T> extends Object implements Function<U,R>
  • Field Details

    • combiner

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

      private final T t
  • Constructor Details

    • FlatMapWithCombinerInner

      FlatMapWithCombinerInner(BiFunction<? super T,? super U,? extends R> combiner, T t)
  • Method Details

    • apply

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