(interceptors []StreamServerInterceptor)
| 1573 | } |
| 1574 | |
| 1575 | func chainStreamInterceptors(interceptors []StreamServerInterceptor) StreamServerInterceptor { |
| 1576 | return func(srv any, ss ServerStream, info *StreamServerInfo, handler StreamHandler) error { |
| 1577 | return interceptors[0](srv, ss, info, getChainStreamHandler(interceptors, 0, info, handler)) |
| 1578 | } |
| 1579 | } |
| 1580 | |
| 1581 | func getChainStreamHandler(interceptors []StreamServerInterceptor, curr int, info *StreamServerInfo, finalHandler StreamHandler) StreamHandler { |
| 1582 | if curr == len(interceptors)-1 { |
no test coverage detected