Pression aval
avec RxJava
![ParisJUG](images/logo/parisjug.png)
![elsass cola](images/elsass-cola.jpeg)
![cola](images/cola-drink.webp)
![cola fail](images/cola-fail.webp)
![cola straw](images/cola-straw.webp)
![Back pressure regulator](images/fluid-back-pressure-regulator.jpg)
![ReactiveX](images/logo/reactivex.png)
- Observable<T>
- subscribe(Observer<? super T> observer)
- Observer<T>
- onNext(T item)
- onError(Throwable throwable)
- onComplete()
- onSubscribe(Disposable subscription)
![ReactiveX](images/logo/reactivex.png)
observable.map(Data::new)
.subscribe(
this::handleNext,
this::handleError,
this::handleEnd
);
![ReactiveX](images/logo/reactivex.png)
- Observable<T>
- subscribe(Observer<? super T> observer)
- Observer<T>
- onNext(T item)
- onError(Throwable throwable)
- onComplete()
- onSubscribe(Disposable subscription)
![ReactiveX](images/logo/reactivex.png)
- 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)
![cola straw fail](images/cola-straw-fail.webp)