hey folks, How can I catch any exception in the sink callback of a stream when I put something in the stream ?