19 Controlling backpressure with subscription classes (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:
/ @java.brains
Website:
www.javabrains.io
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.

[@samehmouldi2289]

This tutorial on reactive programming is by far the best one I've found on KZbin! Clear explanations, great examples, and incredibly helpful in understanding the concepts. Kudos to the presenter for such an excellent job!

[@kappaj01]

Excellent explanation - super series so far!

[@yossiyaari3760]

Good stuff. I had some issues with this, but that was because the source had extra features that needed to be handled in a flatmap method, making this functionality "irrelevant".

[@rajatshah2006]

My processing is not getting stopped even i requested only for 1 element hookOnSubscribe method ..it is printing all

[@ritugupta3367]

Hi Kaushik Sir, Could you please make video on how to read the official Docs ? eg for like Spring docs, java docs .

[@kaustubhdixit8278]

Best explanation on youtube

[@icemush5246]

These ''hooks' look similar to React hook. Are there any something similar to memo hook as well, where you memorise the value and the next time you encounter the same input through subscribtion, we give out the memorised value?

[@michal234486]

It's weird as in the method meant to process what's coming we are also setting the condition on how much more will come. So it smells like combining irrelevant aspects...

[@prernapagade7896]

When i executed code without request method it was still printing all integers 🙄

[@pratushbose1469]

I received the same error. Turn out that my method signature for hookOnSubscribe wasn't correct. I used public void hookOnSubscribe(), instead of public void hookOnSubscribe(Subscription subscription)

[@duyhoang]

check if you are using the correct import statement for subscription (that one from reactive stream and not from flow).

[@sumitroy7817]

@@duyhoang facing the same issue, and signature is correct too. observation: VS code is underlining this method with yellow, saying never used locally

[@hyperborean72]

complicate but nice tutorial

[@recepkucek3016]

Reminded me, "Please Lord help me get one more!(Hacksaw Ridge)"