(msg any)
| 839 | } |
| 840 | |
| 841 | func (cc *headerInspectingClientConn) Send(msg any) error { |
| 842 | if !cc.inspectedRequest { |
| 843 | cc.inspectRequestHeader(cc.Spec(), cc.RequestHeader()) |
| 844 | cc.inspectedRequest = true |
| 845 | } |
| 846 | return cc.StreamingClientConn.Send(msg) |
| 847 | } |
| 848 | |
| 849 | func (cc *headerInspectingClientConn) Receive(msg any) error { |
| 850 | err := cc.StreamingClientConn.Receive(msg) |
nothing calls this directly
no test coverage detected