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<Downstream,Upstream>

Interface to map/wrap a downstream Subscriber to an upstream Subscriber.

Method Summary

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

Method Detail

apply

@NonNull
@NonNull org.reactivestreams.Subscriber<? super Upstream> apply(@NonNull
                                                                         @NonNull org.reactivestreams.Subscriber<? super 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