Giriş
Hem Subscriber hem Publisher olarak davranır.
Tanımlama
Şöyle yaparız. SubmissionPublisher'dan kalıtarak asenkron publisher olur.
İşlenecek veri kalmamıştır. Örnek ver.
onError metodu
Ölümcül bir hata olmuştur. Örnek ver.
onSubscribe metodu
Subscription nesnesi saklanır ve bu nesnenin request() metodu çağrılır.
Örnek ver.
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.
Ölümcül bir hata olmuştur. Örnek ver.
Subscription nesnesi saklanır ve bu nesnenin request() metodu çağrılır.
Örnek ver.
Hiç yorum yok:
Yorum Gönder