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 Detail

      • apply

        @NonNull
@NonNull org.reactivestreams.Subscriber<? super Upstream> apply​(@NonNull
                                                                @NonNull org.reactivestreams.Subscriber<? super @NonNull Downstream> subscriber)
                                                         throws java.lang.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:
        java.lang.Throwable - on failure