diff --git a/src/ray/gcs/redis_context.h b/src/ray/gcs/redis_context.h index 491057894..1d0a6f788 100644 --- a/src/ray/gcs/redis_context.h +++ b/src/ray/gcs/redis_context.h @@ -89,19 +89,19 @@ class RedisCallbackManager { : callback_(callback), is_subscription_(is_subscription), start_time_(start_time), - io_service_(io_service) {} + io_service_(&io_service) {} void Dispatch(std::shared_ptr &reply) { std::shared_ptr self = shared_from_this(); if (callback_ != nullptr) { - io_service_.post([self, reply]() { self->callback_(std::move(reply)); }); + io_service_->post([self, reply]() { self->callback_(std::move(reply)); }); } } RedisCallback callback_; bool is_subscription_; int64_t start_time_; - boost::asio::io_service &io_service_; + boost::asio::io_service *io_service_; }; int64_t add(const RedisCallback &function, bool is_subscription,