Flow.Processor (Java SE 17 & JDK 17)

Type Parameters:: T - the subscribed item type; R - the published item type

All Superinterfaces:: Flow.Publisher<R>, Flow.Subscriber<T>

Enclosing class:: Flow

public static interface Flow.Processor<T,R> extends Flow.Subscriber<T>, Flow.Publisher<R>

A component that acts as both a Subscriber and Publisher.

Method Summary

Methods declared in interface java.util.concurrent.Flow.Publisher
subscribe

Methods declared in interface java.util.concurrent.Flow.Subscriber
onComplete, onError, onNext, onSubscribe