transporter
transporter copied to clipboard
better error handling from adaptors up through the pipeline
There are critical errors that should stop the pipeline and there are other errors that just need to be logged. Right now, things bubble up through the pipe.Err
chan and get processed by a go routine in pipeline. This works for most cases but it can also cause a panic due to Stop()
getting called twice for an adaptor.