Hystrix v1.3.0 Release Notes
-
This version integrations Hystrix with RxJava to enable non-blocking reactive execution and functional composition.
Async execution can now be done reactively with the
observe()method and it will callback when the value is received:Observable<String> s = new CommandHelloWorld("World").observe();A simple example of subscribing to the value (using a Groovy lambda instead of anonymous inner class):
s.subscribe({ value -> println(value) })A "Hello World" example of reactive execution can be found on the wiki.
More can be learned about RxJava and the composition features at https://github.com/Netflix/RxJava/wiki
🚀 This release is a major refactoring of the Hystrix codebase. To assert correctness and performance it was run in production canary servers on the Netflix API several times during development and for over a week during release candidate stages. Prior to this release the 1.3.0.RC1 version has been running in full Netflix API production for several days performing billions of executions a day.