RxJava 2 : Reactive Programming using Java

Learn to build an observable from scratch in RxJava 2 using create, emit shapes (square, hexagon, pentagon, star) with colors, and manage on next, on error, and on complete.

Explore observable using timer in RxJava 2 to emit a single event after a delay, compare with interval, and subscribe with on next and on complete.

Discover RxJava 2's observable range, which emits a sequence from a starting number for a given count, shown by a range from 2 with 10 items on the main thread.

Compare observable without backpressure and flowable with backpressure, showing how flowable uses buffers and request-based delivery to prevent memory overflow, with examples of subscribe on and observe on.

Explore the debounce operator in RxJava 2, which emits items only after a period of user inactivity, illustrated by typing in a search box and waiting for results.

The lecture introduces the distinct operator in RxJava 2, showing how it removes duplicates from the stream to display only unique elements and previews the next operator.

Learn the ignore elements operator in RxJava 2 to ignore all emitted items while still signaling completion or error, as shown when no elements are printed.

Explore the skip and skip last operators in RxJava 2, which ignore the first or last elements of a stream, demonstrated with a marble diagram and subscribe behavior.

The filter operator in RxJava 2 filters a stream based on a condition, passing only items that meet it, such as colors blue or green, while others are ignored.

Explore the RxJava 2 zip operator, which combines multiple streams with a defined function and emits joined results as events align, illustrated with a marble diagram.

Add timestamps to each event with a time stamp operator, then enforce timely emissions using a timeout operator in reactive programming, triggering errors when stream stalls and showing error handling.