(interceptors []StreamServerInterceptor, curr int, info *StreamServerInfo, finalHandler StreamHandler)
| 1579 | } |
| 1580 | |
| 1581 | func getChainStreamHandler(interceptors []StreamServerInterceptor, curr int, info *StreamServerInfo, finalHandler StreamHandler) StreamHandler { |
| 1582 | if curr == len(interceptors)-1 { |
| 1583 | return finalHandler |
| 1584 | } |
| 1585 | return func(srv any, stream ServerStream) error { |
| 1586 | return interceptors[curr+1](srv, stream, info, getChainStreamHandler(interceptors, curr+1, info, finalHandler)) |
| 1587 | } |
| 1588 | } |
| 1589 | |
| 1590 | func (s *Server) processStreamingRPC(ctx context.Context, stream *transport.ServerStream, info *serviceInfo, sd *StreamDesc, trInfo *traceInfo) (err error) { |
| 1591 | if channelz.IsOn() { |
no outgoing calls
no test coverage detected