Java 9 Flow.Processor Arayüzü

Giriş
Hem Subscriber hem Publisher olarak davranır.

Tanımlama
Şöyle yaparız. SubmissionPublisher'dan kalıtarak asenkron publisher olur.

public class MyProcessor<T, R> extends SubmissionPublisher<R>
                               implements Flow.Processor<T, R> {       
  private Function function;
  MyProcessor(Function<? super T, ? extends R> function) {  
    super();  
    this.function = function;  
  } 
  ...
} 

onComplete metodu
İşlenecek veri kalmamıştır. Örnek ver.

onError metodu
Ölümcül bir hata olmuştur. Örnek ver.

onNext metodu
İşlenecek yeni veri gelmiştir.
Örnek ver.

onSubscribe metodu
Subscription nesnesi saklanır ve bu nesnenin request() metodu çağrılır.
Örnek ver.