diff --git a/native/cpp/CommonCpp/grpc/ClientGetReadReactor.cpp b/native/cpp/CommonCpp/grpc/ClientGetReadReactor.cpp --- a/native/cpp/CommonCpp/grpc/ClientGetReadReactor.cpp +++ b/native/cpp/CommonCpp/grpc/ClientGetReadReactor.cpp @@ -22,6 +22,10 @@ } void ClientGetReadReactor::close() { + { + std::lock_guard guard{this->setReadyStateMutex}; + this->setReadyState(SocketStatus::CLOSING); + } this->context.TryCancel(); }