Skip to content

Commit

Permalink
Serialize onCompleteFailure for #9059 (#9062)
Browse files Browse the repository at this point in the history
Serialize onCompleteFailure for #9059

* Fixed case where process() throws an exception.
   Before, exiting the processing loop would always skip to invoke onCompleteFailure(), causing the callback to not be completed.
   Now we fall through and possibly invoke onCompleteFailure() if it was not already invoked.

* Updated javadocs.

* Code cleanups.

Co-authored-by: Simone Bordet <simone.bordet@gmail.com>
  • Loading branch information
gregw and sbordet committed Dec 16, 2022
1 parent 6e82e70 commit d24a521
Showing 1 changed file with 157 additions and 106 deletions.

0 comments on commit d24a521

Please sign in to comment.