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