by Tomasz Lelek | Released March 2019 | ISBN: 9781789808773

Using the reactive paradigm to create fast and non-blocking appsAbout This VideoUnderstand the purpose behind RxJava development and use the right tools to make your application Reactive and asynchronousApply Reactive principles with Java to make your app responsive, reliable, and scalableImplement backpressure with Reactive constructs: subscription and subscriberIn DetailReactive programming is a programming paradigm oriented toward data flows and the propagation of change: programming with asynchronous data streams. Apps in recent times have an abundance of real-time events of every kind that create a highly interactive experience for the user. However, the right tools are needed to manage these, and Reactive programming is the answer.This course is a step-by-step guide to creating applications with Java 12 by applying Reactive programming. You will get hands-on experience; each section will build on the previous one, so that you will be able to make your app responsive and reliable by implementing Reactive principles with Java. You'll also apply the best data structures and algorithms that optimize functions - all using functional Reactive programming.By the end of this course, you'll be fully equipped with the tools and techniques needed to implement robust, event-driven, and Reactive applications. Show and hide more Publisher resources Download Example Code

1. Chapter 1 : Reactive API – Most Important Aspects
   • The Course Overview 00:02:23
   • Flow: The Main Entry Point of Every Reactive App 00:05:12
   • Subscriber versus Publisher: When to Use Which 00:05:48
   • Hot Publisher: Why It Is Hard to Take Control Over It 00:04:13
   • Cold Publisher: Pairing with Back Pressure 00:04:29
2. Chapter 2 : Publishing and Consuming Messages
   • Consuming Messages: Creating a Subscriber 00:04:48
   • Using Publisher to Emit Stock Events 00:03:04
   • Testing Stock Reactive Flow 00:04:16
   • Handling Errors in Subscriber 00:05:57
3. Chapter 3 : Transformation of Messages
   • Flow.Processor API for the Skeleton of Transformation 00:04:47
   • Using SubmissionPublisher for Proxying Event to Another Publisher in the Chain 00:02:33
   • Plugging the TransformProcessor for Transformation Logic 00:03:24
   • Testing Stock Transformation Logic 00:04:37
4. Chapter 4 : Overproducing Publisher with Backpressure
   • Leveraging Subscription Object for Controlling the Number of Fetched Stocks 00:04:49
   • Controlling the Speed of Consumer with AtomicInteger 00:04:39
   • Creating Overproducing Publisher 00:04:51
   • Testing Backpressure in Stock Exchange Application 00:03:15
5. Chapter 5 : Reactive Java 12 with Alternative Implementations
   • RxJava – Observables Abstractions 00:04:55
   • RxJava – Advanced Operations – flatMap 00:05:09
   • Reactor – Flux 00:05:07
   • Reactor – Combining Publishers 00:04:59
6. Chapter 6 : Reactive Microservices
   • Reactive Spring Boot 00:04:26
   • Creating Reactive Data Access Layer 00:05:34
   • Creating Reactive Controller 00:03:04
   • Testing Reactive Microservices 00:05:34
Show and hide more