Add Error recovery mechanism when the processing failed

[cescoffier]

Several approaches:

1. Failed the stream (current)
2. Mailbox collecting error, but continue the streams