diff --git a/src/objective-c/GRPCClient/GRPCCall.m b/src/objective-c/GRPCClient/GRPCCall.m index e2625a63e19..0e8bb469f78 100644 --- a/src/objective-c/GRPCClient/GRPCCall.m +++ b/src/objective-c/GRPCClient/GRPCCall.m @@ -771,6 +771,9 @@ const char *kCFStreamVarName = "grpc_cfstream"; @synchronized(self) { _pendingReceiveNextMessages += numberOfMessages; + if (_state != GRXWriterStateStarted || !_callOptions.enableFlowControl) { + return; + } [self maybeStartNextRead]; } }