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 <[email protected]>
  • Loading branch information
@gregw @sbordet
gregw and sbordet committed Dec 20, 2022
1 parent 1b727a0 commit 999fe87
Showing 1 changed file with 170 additions and 130 deletions.
Loading

0 comments on commit 999fe87

Please sign in to comment.