Package io.reactivex.rxjava3.core

Interface FlowableOperator<Downstream,Upstream>

Type Parameters:
Downstream - the value type of the downstream
Upstream - the value type of the upstream
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface public interface FlowableOperator<@NonNull Downstream,@NonNull Upstream>
Interface to map/wrap a downstream Subscriber to an upstream Subscriber.

  • Method Summary

    Modifier and Type
    Method
    Description
    @NonNull org.reactivestreams.Subscriber<? super Upstream>
    apply(@NonNull org.reactivestreams.Subscriber<? super @NonNull Downstream> subscriber)
    Applies a function to the child Subscriber and returns a new parent Subscriber.

  • Method Details

    • apply

      @NonNull @NonNull org.reactivestreams.Subscriber<? super Upstream> apply(@NonNull @NonNull org.reactivestreams.Subscriber<? super @NonNull Downstream> subscriber) throws Throwable
      Applies a function to the child Subscriber and returns a new parent Subscriber.
      Parameters:
      subscriber - the child Subscriber instance
      Returns:
      the parent Subscriber instance
      Throws:
      Throwable - on failure