T
R
public static interface Flow.Processor<T,R> extends Flow.Subscriber<T>, Flow.Publisher<R>
onComplete, onError, onNext, onSubscribe
subscribe