File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -542,7 +542,7 @@ type clientStream struct {
542542
543543 sentLast bool // sent an end stream
544544
545- recvMsg bool // received msg from server
545+ recvFirstMsg bool // received first msg from server
546546
547547 methodConfig * MethodConfig
548548
@@ -1136,7 +1136,7 @@ func (a *csAttempt) recvMsg(m any, payInfo *payloadInfo) (err error) {
11361136 if statusErr := a .transportStream .Status ().Err (); statusErr != nil {
11371137 return statusErr
11381138 }
1139- if cs .desc .ClientStreams && ! cs .desc .ServerStreams && ! cs .recvMsg {
1139+ if cs .desc .ClientStreams && ! cs .desc .ServerStreams && ! cs .recvFirstMsg {
11401140 return status .Errorf (codes .Internal , "client streaming cardinality violation" )
11411141 }
11421142 return io .EOF // indicates successful end of stream.
@@ -1145,7 +1145,7 @@ func (a *csAttempt) recvMsg(m any, payInfo *payloadInfo) (err error) {
11451145 return toRPCErr (err )
11461146 }
11471147 if cs .desc .ClientStreams {
1148- cs .recvMsg = true
1148+ cs .recvFirstMsg = true
11491149 }
11501150 if a .trInfo != nil {
11511151 a .mu .Lock ()
You can’t perform that action at this time.
0 commit comments