@@ -403,7 +403,7 @@ AsyncConnectionImpl::AppendableObjectUploadImpl(AppendableUploadParams p) {
403403 return pending.then (
404404 [current, request = std::move (p.request ), persisted_size,
405405 fa = std::move (factory)](auto f) mutable
406- -> StatusOr<std::unique_ptr<storage::AsyncWriterConnection>> {
406+ -> StatusOr<std::unique_ptr<storage::AsyncWriterConnection>> {
407407 auto rpc = f.get ();
408408 if (!rpc) return std::move (rpc).status ();
409409
@@ -470,7 +470,7 @@ AsyncConnectionImpl::StartBufferedUpload(UploadParams p) {
470470 return StartUnbufferedUpload (std::move (p))
471471 .then ([current = std::move (current),
472472 async_write_object = std::move (async_write_object)](auto f) mutable
473- -> StatusOr<std::unique_ptr<storage::AsyncWriterConnection>> {
473+ -> StatusOr<std::unique_ptr<storage::AsyncWriterConnection>> {
474474 auto w = f.get ();
475475 if (!w) return std::move (w).status ();
476476 auto factory = [upload_id = (*w)->UploadId (),
@@ -504,15 +504,14 @@ AsyncConnectionImpl::ResumeBufferedUpload(ResumeUploadParams p) {
504504 };
505505
506506 auto f = make_unbuffered ();
507- return f.then (
508- [current = std::move (current),
509- make_unbuffered = std::move (make_unbuffered)](auto f) mutable
510- -> StatusOr<std::unique_ptr<storage::AsyncWriterConnection>> {
511- auto w = f.get ();
512- if (!w) return std::move (w).status ();
513- return MakeWriterConnectionBuffered (std::move (make_unbuffered),
514- *std::move (w), *current);
515- });
507+ return f.then ([current = std::move (current),
508+ make_unbuffered = std::move (make_unbuffered)](auto f) mutable
509+ -> StatusOr<std::unique_ptr<storage::AsyncWriterConnection>> {
510+ auto w = f.get ();
511+ if (!w) return std::move (w).status ();
512+ return MakeWriterConnectionBuffered (std::move (make_unbuffered),
513+ *std::move (w), *current);
514+ });
516515}
517516
518517future<StatusOr<google::storage::v2::Object>>
0 commit comments