pub async fn connect<Buffer: ToBuffer + Debug + Send + Sync + 'static>( reader: PipeRead, writer: PipeWrite) -> Result<(WriteEnd<Buffer>, ReadEnd<Buffer>), Error>
