Netflix/Hystrix 1.3.0

Version 1.3.0

on GitHub

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.

• Pull 151 Version 1.3 - RxJava Observable Integration
• Pull 158 Expose current HystrixCommand to fns

Artifacts: Maven Central