GitXplorerGitXplorer
v

failsafe-rxjava2

public
1 stars
0 forks
0 issues

Commits

List of commits on branch master.
Unverified
6a4c03ef7281b18233e8b8d76bbb06b51a402edb

corrected maven central badge

vventh committed 7 years ago
Unverified
576f717c5ef7b1235ca4c2cbd6ee80a7961435bf

corrected travis build badge

vventh committed 7 years ago
Unverified
d9c24244b3126d001014c6398832d76468874e2d

added uploading archives to release chain

vventh committed 7 years ago
Unverified
f06f2f78b172e37d3a5b23ec72b42c76cd512105

archive generated javadocs

vventh committed 7 years ago
Unverified
92da79ddff18525a9461fbee995567a1d6da2dbc

fixing project's version

vventh committed 7 years ago
Unverified
e0b4b070058b0e4d0da0e8ee253d3e9be6d30007

added project version based on axion plugin

vventh committed 7 years ago

README

The README file for this repository.

Circuit Breaker Operator for RxJava2 (ReactiveX)

Build Status Maven Central 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 rxjava2 circuit breaker operator based on FailSafe which aims to be easy to use.

Usage

gradle

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

maven

<dependency>
    <groupId>com.github.venth.failsafe</groupId>
    <artifactId>rxjava2</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.

Maybe

maybeSequence.lift(CircuitBreakerOperator.of(circuitBreaker))
    .subscribe()

Single

singleSequence.lift(CircuitBreakerOperator.of(circuitBreaker))
    .subscribe()

Observable

observableSequence.lift(CircuitBreakerOperator.of(circuitBreaker))
    .subscribe()

Flowable

flowableSequence.lift(CircuitBreakerOperator.of(circuitBreaker))
    .subscribe()

Completable

completableSequence.lift(CircuitBreakerOperator.of(circuitBreaker))
    .subscribe()