fix

1 year ago · 92f759d763
parent cdac34cca7
commit 92f759d763
1 changed files with 2 additions and 1 deletions
--- a/src/core/lib/surface/call.cc
+++ b/src/core/lib/surface/call.cc
@ -2978,7 +2978,8 @@ void ClientPromiseBasedCall::CommitBatch(const grpc_op* ops, size_t nops,
        StartRecvMessage(
            op, completion,
            [this]() {
-              return server_initial_metadata_.receiver.AwaitClosed();
+              return Race(server_initial_metadata_.receiver.AwaitClosed(),
+                          server_to_client_messages_.receiver.AwaitClosed());
            },
            &server_to_client_messages_.receiver, false, spawner);
        break;