28 Exercise Using flatMap and distinct operators (Reactive programming with Java - full course)

Course: Reactive programming in Java
Covers: Reactive fundamentals, Project Reactor

Access this full course NOW & unlock more awesome courses like this by becoming a member:

Website:

Learn the basics of reactive programming. You will learn to "THINK REACTIVE" - understand the paradigm shift and thinking change necessary to write code in a reactive way using Project Reactor.

New video every 3 days! Subscribe and enable notifications to be alerted.

[rick_uio]

This is the perfect class to understand Java Reactor Project. Thanks master!

[mostinho]

Done thanks
Calling subscribe is what starts the flux stream, if you don’t call subscribe then it won’t get triggered even if you perform operations on the flux stream

.distinct() operator eliminates repeated values from flux stream

.distinctUntilChanged() will remove repeated values in a row like 1, 1 but will not remove repeated values if they changed in between

Project reactor has operators documentation to find out how each one works to transform the stream and if it is blocking or async

[star_wars_]

Thanks Kaushik for the awesome content!
I binge watched the playlist. Eagerly waiting for rest of the videos :)

[manamohansamal]

For mapping int to its related user we are doing a filter inside a map of the first flux, so isn't that a blocking operation as the id need to wait for the user flux to complete until check for the last element complete the filter operation?

[dadylle]

Subscribe is the contract between the source and the consumer, when data is ready the source push data to observers how are in there subscriber's list, maybe at the time of subscribing there is no data.