cescoffier/rxjava2-lab

A lab about RX Java 2

RX Java 2 Lab

This repository is a lab about RX Java 2 and how to build RX Java API.

The instructions are available on http://escoffier.me/rxjava-hol/.

Teasing

Reactive programming combines functional programming and data streams. In other words it's a bit fuzzy...

RX Java 2 is a library implementing the reactive programing paradigm. In this lab, you learn how to use RX Java 2, the concepts, the operators and the good practices. It explains how RX Java 2 lets you build concurrent applications easily, how to manage errors...but RX Java 2 is not a silver bullet!

This lab also covers how to propose an RX Java API. Indeed, with the reactive movements, lots of blocking and synchronous API are not usable anymore.

Content

• RX Java 2
• Reactive thinking
• The RX Java type of streams
• The operators
• How to build RX API
• Schedulers and concurrency
• Testing

Want to improve this lab?

Forks and pull requests are definitely welcome!

Building

Code:

mvn clean compile

Documentation:

docker run -it -v $(pwd):/documents asciidoctor/docker-asciidoctor "docs/build.sh"    

rxjava2-lab's Issues

Package numbers are off by one

Chapter numbers should match package numbers.

Can't build doc

MBP-de-julien:rxjava2-lab julien$ docker run -it -v $(pwd):/documents/ asciidoctor/docker-asciidoctor "./build.sh" "html"
docker: Error response from daemon: OCI runtime create failed: container_linux.go:296: starting container process caused "exec: \"./build.sh\": stat ./build.sh: no such file or directory": unknown.

Mention `using` in the Operation per subscriber section

http://reactivex.io/RxJava/javadoc/io/reactivex/Flowable.html#using-java.util.concurrent.Callable-io.reactivex.functions.Function-io.reactivex.functions.Consumer-

@FroMage WDYT?

Mention Flowable.parallel in the scheduler chapter

http://reactivex.io/RxJava/javadoc/io/reactivex/Flowable.html#parallel--

999_999_999 is not 10000

in code9 and code 10

// Create an observable emitting all numbers between 1 and 10000
Flowable.range(1, 999_999_999

Should we introduce Flowable earlier

And maybe replace most of our Observable with Flowable. It would also let us talk about Flow

Introduce the format returned by the Super Heroes API

take down the vertx server at the end of mains

or put the lab code in junit tests but for some waiting for user input it does not work