better error handling from adaptors up through the pipeline

[jipperinbham]

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.