Attaches the provided processor and returns a Closeable to release the connection once required. The source does not need to guarantee that the provided processor will be connected to as soon as attached since the the source may need to pull input data asynchronously.