io.reactivex

public Interface FlowableOperator<Downstream, Upstream>

Type Parameters

Imports

io.reactivex.annotations.*, org.reactivestreams.Subscriber

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

Method Summary

Modifier and Type	Method and Description
public Subscriber<? super Upstream>	Returns: the parent Subscriber instance apply(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
public Subscriber<? super Upstream> apply(Subscriber<? super Downstream> subscriber) throws Exception Applies a function to the child Subscriber and returns a new parent Subscriber. Parameters subscriber:Subscriber<? super Downstream> the child Subscriber instance Returns:Subscriber<? super Upstream> the parent Subscriber instance Annotations @NonNull Exceptions Exception: on failure

apply

public Subscriber<? super Upstream> apply(Subscriber<? super Downstream> subscriber) throws Exception

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

Parameters

Returns:Subscriber<? super Upstream>

the parent Subscriber instance

Annotations

Exceptions