io.reactivex.rxjava3.core

public Interface FlowableOperator<Downstream, Upstream>

Annotations

Type Parameters

Imports

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

Method Summary

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

apply back to summary

apply	back to summary
public @NonNull Subscriber<? super Upstream> apply(@NonNull Subscriber<? super Downstream> subscriber) throws Throwable Applies a function to the child `Subscriber` and returns a new parent `Subscriber`. Parameters subscriber:@NonNull Subscriber<? super Downstream> the child `Subscriber` instance Returns:@NonNull Subscriber<? super Upstream> the parent `Subscriber` instance Annotations @NonNull Exceptions Throwable: on failure

public @NonNull Subscriber<? super Upstream> apply(@NonNull Subscriber<? super Downstream> subscriber) throws Throwable

Applies a function to the child Subscriber and returns a new parent Subscriber.

Parameters

subscriber:@NonNull Subscriber<? super Downstream>: the child Subscriber instance

Returns:@NonNull Subscriber<? super Upstream>

the parent Subscriber instance

Annotations

Exceptions