| 125 | } |
| 126 | |
| 127 | type auditConnectStreamingConn struct { |
| 128 | connect.StreamingHandlerConn |
| 129 | interceptor *AuditInterceptor |
| 130 | ctx context.Context |
| 131 | method string |
| 132 | curRequest any |
| 133 | startTime time.Time |
| 134 | } |
| 135 | |
| 136 | func (c *auditConnectStreamingConn) Receive(msg any) error { |
| 137 | err := c.StreamingHandlerConn.Receive(msg) |
nothing calls this directly
no outgoing calls
no test coverage detected