diff --git a/third-party/folly/src/folly/experimental/channels/MultiplexChannel-inl.h b/third-party/folly/src/folly/experimental/channels/MultiplexChannel-inl.h index d5fdf57972fec..6472d94330443 100644 --- a/third-party/folly/src/folly/experimental/channels/MultiplexChannel-inl.h +++ b/third-party/folly/src/folly/experimental/channels/MultiplexChannel-inl.h @@ -201,9 +201,9 @@ class MultiplexChannelProcessor : public IChannelCallback { [this, key = std::move(key), subscriptionArg = std::move(subscriptionArg), - sender = std::move(sender)]() mutable -> folly::coro::Task { + sender_2 = std::move(sender)]() mutable -> folly::coro::Task { co_await processNewSubscription( - std::move(key), std::move(subscriptionArg), std::move(sender)); + std::move(key), std::move(subscriptionArg), std::move(sender_2)); }); return std::move(receiver); } @@ -214,8 +214,8 @@ class MultiplexChannelProcessor : public IChannelCallback { std::vector>>(); executeWithMutexWhenReady( [this, - promise = std::move(promise)]() mutable -> folly::coro::Task { - co_await processClearUnusedSubscriptions(std::move(promise)); + promise_2 = std::move(promise)]() mutable -> folly::coro::Task { + co_await processClearUnusedSubscriptions(std::move(promise_2)); }); return folly::coro::toTask(std::move(future)); }