Fix race condition on bidirectional streaming

Makefile

@@ -18,6 +18,9 @@ ci: depsdev test
 test: cert
 	go test ./... -coverprofile=coverage.out -covermode=count
 
+race:
+	go test ./... -race
+
 lint:
 	golangci-lint run ./...
 

grpc.go

@@ -344,6 +344,7 @@ L:
 				return err
 			}
 			err = stream.SendMsg(req)
+			req.Reset()
 		case grpcOpRecieve:
 			res, err := stream.RecvMsg()
 			stat, ok := status.FromError(err)
@@ -373,7 +374,6 @@ L:
 		default:
 			return fmt.Errorf("invalid op: %v", m.op)
 		}
-		req.Reset()
 	}
 	stat, ok := status.FromError(err)
 	if !ok {
@@ -409,6 +409,12 @@ L:
 		}
 	}
 
+	// If the connection is not disconnected here, it will fall into a race condition when retrieving the trailer.
+	if err := rnr.cc.Close(); err != nil {
+		return err
+	}
+	rnr.cc = nil
+
 	d["messages"] = messages
 	if h, err := stream.Header(); err == nil {
 		d["headers"] = h