Reactive programming and Hystrix fault tolerance
summary
Shows building a reactive client with RxJava Observables and wrapping remote calls in Hystrix commands and circuit breaker units. Demonstrates pipelines: fetch category → product IDs → flatMap to product and reviews, generate three review items per product, and stop the stream when a value exceeds 100. Uses operators (map, flatMap, zip, merge), schedulers (computation, io), and onErrorResume to return an empty list as fallback. Hystrix dashboard reports percentiles and latency; at ~50% failure the breaker opens and fallbacks are served.
AI-written summary · about
chapters (9)
- 0:00Reactive programming intro
- 1:05Reactivity overview
- 8:38Core operations
- 11:30Hot vs cold observables
- 12:33RxJava schedulers
- 16:36Hystrix fault tolerance
- 24:59Python parallelism example
- 33:58onSubscribe subscription
- 34:19Conclusion
related talks
52mReactive Programming in Java
41mThe definite guide to reactive programming in Java
47mReactive programming in Java
58mReactive Spring
47mReactive Spring
01h 32mBuilding Reactive applications with Reactor and the Reactive Streams standard
24mBringing Reactive Programming to Java and Microservices
53mRefactor to Reactive with Spring 5 and Project Reactor
