Downstream
- the value type of the downstreamUpstream
- the value type of the upstreampublic interface FlowableOperator<Downstream,Upstream>
Modifier and Type | Method and Description |
---|---|
Subscriber<? super Upstream> |
apply(Subscriber<? super Downstream> subscriber)
Applies a function to the child Subscriber and returns a new parent Subscriber.
|
@NonNull Subscriber<? super Upstream> apply(@NonNull Subscriber<? super Downstream> subscriber) throws Exception
subscriber
- the child Subscriber instanceException
- on failure