Pression aval
avec RxJava
- Observable<T>
- subscribe(Observer<? super T> observer)
- Observer<T>
- onNext(T item)
- onError(Throwable throwable)
- onComplete()
- onSubscribe(Disposable subscription)
observable.map(Data::new)
.subscribe(
this::handleNext,
this::handleError,
this::handleEnd
);- Observable<T>
- subscribe(Observer<? super T> observer)
- Observer<T>
- onNext(T item)
- onError(Throwable throwable)
- onComplete()
- onSubscribe(Disposable subscription)
- Flowable<T>
- subscribe(Observer<? super T> observer)
- Observer<T>
- onNext(T item)
- onError(Throwable throwable)
- onComplete()
- onSubscribe(Disposable subscription)
- Flow.Publisher<T>
- subscribe(Flow.Subscriber<? super T> observer)
- Flow.Subscriber<T>
- onNext(T item)
- onError(Throwable throwable)
- onComplete()
- onSubscribe(Flow.Subscription subscription)
