Run the RxJava application

- [Instructor] Okay, let's spend a bit more time speaking…about what is happening behind the scenes.…Let's open up a terminal…and let's invoke the Gradle Wrapper…and execute bootRun.…Our string boot application is now starting up.…We print out our title…and then at each three second tick,…we get a timestamp from local daytime.…

We get the type of cryptocurrency,…we get the current buy price,…and we get the type of currency,…a US dollar, in this case.…And if you look at the timestamp,…you could see that it's ticking every three seconds.…Each tick represents a new call to the Coinbase API.…Okay, let's review what's happening.…

The observable we declared emits a tick every three seconds.…The tick is mapped to a call to the Coinbase service.…The Observable emits a Mono…of the type CoinbaseResponse.…We use a instance of the ConsolePrintObserver…to subscribe to that Observable.…Then in the onNext method in our ConsolePrintObserver,…the response is consumed by a lambda…that prints out a timestamp and the data from the response.…

Resume Transcript Auto-Scroll

Author

Released

6/26/2018

Java developers face many challenges: complex distributed systems, high expectations for responsiveness and performance, and more users and data than ever before. Reactive programming offers a solution. Follow along with instructor Chris Anatalio and learn how to write asynchronous, concurrent, and resilient applications in Java 8 using popular reactive frameworks such as RxJava and Akka. Learn how to pair reactive programming with functional programming, which breaks software into small modular pieces made up of functions that reduce cognitive load and complexity. Chris then surveys major reactive frameworks—RxJava, Akka, Vert.x, and Spring 5.0—and selects two, RxJava and Akka, to demo. Learn how to use each framework to bootstrap apps as well as build complete applications from scratch. In the final chapters, Chris shows how to write unit tests for RxJava and Akka applications and reviews the final projects.