Since introduction of Spring Reactive appeared a need of a circuit breaker that would follow the reactive principles and is very light.

FailSafe provides very light circuit breaker which works perfectly with Callable and Runnable and is complicated when comes to an application on an observable sequence.

This project brings new spring reactor circuit breaker operator based on FailSafe which aims to be easy to use.

compile 'com.github.venth.failsafe:reactor:x.y.z'

<dependency>
    <groupId>com.github.venth.failsafe</groupId>
    <artifactId>reactor</artifactId>
    <version>x.y.z</version>
</dependency>

Usage for each of the ReactiveX observables type is pretty similar. The examples presented below shall explain the usage.

• xxxSequence - a sequence that depends on the operator's type.
• circuitBreaker is configured instance of FailSafe CircuitBreaker.

fluxSequence.transform(CircuitBreakerOperator.of(circuitBreaker))

monoSequence.transform(CircuitBreakerOperator.of(circuitBreaker))