Don't let errors in the pipeline crash the whole reactor
Make things non-blocking before using them as reactor channels