Understanding Reactive Streams in Java
Understanding Reactive Streams in Java

Understanding Reactive Streams in Java

Author
Shiv Bade
Tags
rxjava
reactive
backpressure
Published
April 30, 2015
Featured
Slug
Tweet
With Reactive Streams picking up momentum, I explored RxJava in a pet project.
Highlights: - Observable chains made transformation pipelines elegant - Backpressure helps handle overload gracefully - Debugging flow was hard — tooling needs to catch up
Sample:
Observable.just("a", "b", "c") .map(String::toUpperCase) .subscribe(System.out::println);
Promising model — but needs discipline.