What are some examples of reactive programming in Java?

What are some examples of reactive programming in Java?

Reactive programming in Java often involves using libraries like RxJava or Project Reactor. For example, you can create a simple observable that emits a sequence of numbers.

Can you show me a code snippet for that?

Sure! Here's a basic example using RxJava:

Observable<Integer> numbers = Observable.range(1, 5);
numbers.subscribe(System.out::println);

This will print numbers from 1 to 5.

What about handling errors in reactive streams?

You can handle errors using the onError method. For example:

numbers.subscribe(System.out::println, Throwable::printStackTrace);

Are there any real-world applications of reactive programming?

Yes, reactive programming is widely used in applications that require real-time data processing, like chat applications, live dashboards, and streaming services.