[Enhancement]: When an unrecoverable error occurs, return instead of swap

[fengjun2016]

Is there an existing issue for this?

• I have searched the existing issues

What would you like to be added?

When an unrecoverable error occurs, return error directly instead of swap

Why is this needed?

Anything else?

No response

[chyezh]

/assign

[chyezh]

thx for your catch.

producerWithResumingError type is a utility type to handle the Condvar logic for ResumableProducer.
So after creating the producer, we must record the error and producer in producerWithResumingError to notify the method Produce.

So we cannot move the SwapProducer to the position after error handling.

[chyezh]

closed, as previous comment.