io.reactivex

Interface FlowableOperator

Type Parameters:

Downstream - the value type of the downstream

Upstream - the value type of the upstream

public interface FlowableOperator

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

Method Summary

Modifier and Type	Method and Description
SubscriberUpstream>	apply(SubscriberDownstream> subscriber) Applies a function to the child Subscriber and returns a new parent Subscriber.

Method Detail

apply

@NonNull
SubscriberUpstream> apply(@NonNull
                                            SubscriberDownstream> subscriber)
                                     throws Exception

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:

Exception - on failure