search

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

Calls StreamObserver.onStop only on termination. #290

Closed dehora closed 7 years ago

dehora commented 7 years ago

This calls onStop once, when the processor is being stopped. It also documents onCompleted as being called after a processor has finished due to being configure ot fetch only a subset. Previously onStop was being called multiple times, for example on every retry.

For #289.