Coro::DataPipe::run implemented