Routes rxjava undeliverable exceptions to a handler.

dehora / nakadi-java

🌀 Client library for the Nakadi Event Broker (examples: http://bit.ly/njc-examples, site: https://dehora.github.io/nakadi-java/)

MIT License

30 stars 19 forks source link

Routes rxjava undeliverable exceptions to a handler. #274

Closed dehora closed 7 years ago

dehora commented 7 years ago

The hanlder warns on a RejectedExecutionException as this can happen between one processor stopping and new one starting if the old one is canceled mid-flight.

For #225.