Closed ocadaruma closed 3 years ago
ProcessingContext#deferCompletion()
Completion
deferCompletion()
ProcessorTestSuite
Motivation
ProcessingContext#deferCompletion()
that:Completion
instance returned fromdeferCompletion()
if we want to refer it later, otherwise completion will be leakedProcessorTestSuite
to await retried-produced tasks to be committed