I am trying to figure out how can I convert a "error" event into a "done" event but can't find a way.

Example: I have a timeout operator on my stream and want it to close the stream intead of transmitting the error.

Is there a way of doing it?

Perhaps a onErrorClose event could be an interesting addition? What you think?