type google.golang.org/grpc.StreamServerInterceptor
10 uses
google.golang.org/grpc (current package)
interceptor.go#L104: type StreamServerInterceptor func(srv any, ss ServerStream, info *StreamServerInfo, handler StreamHandler) error
server.go#L159: streamInt StreamServerInterceptor
server.go#L161: chainStreamInts []StreamServerInterceptor
server.go#L488: func StreamInterceptor(i StreamServerInterceptor) ServerOption {
server.go#L501: func ChainStreamInterceptor(interceptors ...StreamServerInterceptor) ServerOption {
server.go#L1548: interceptors = append([]StreamServerInterceptor{s.opts.streamInt}, s.opts.chainStreamInts...)
server.go#L1551: var chainedInt StreamServerInterceptor
server.go#L1563: func chainStreamInterceptors(interceptors []StreamServerInterceptor) StreamServerInterceptor {
server.go#L1569: func getChainStreamHandler(interceptors []StreamServerInterceptor, curr int, info *StreamServerInfo, finalHandler StreamHandler) StreamHandler {