type google.golang.org/grpc.StreamServerInterceptor
10 uses
google.golang.org/grpc (current package)
interceptor.go#L108: type StreamServerInterceptor func(srv any, ss ServerStream, info *StreamServerInfo, handler StreamHandler) error
server.go#L162: streamInt StreamServerInterceptor
server.go#L164: chainStreamInts []StreamServerInterceptor
server.go#L506: func StreamInterceptor(i StreamServerInterceptor) ServerOption {
server.go#L519: func ChainStreamInterceptor(interceptors ...StreamServerInterceptor) ServerOption {
server.go#L1560: interceptors = append([]StreamServerInterceptor{s.opts.streamInt}, s.opts.chainStreamInts...)
server.go#L1563: var chainedInt StreamServerInterceptor
server.go#L1575: func chainStreamInterceptors(interceptors []StreamServerInterceptor) StreamServerInterceptor {
server.go#L1581: func getChainStreamHandler(interceptors []StreamServerInterceptor, curr int, info *StreamServerInfo, finalHandler StreamHandler) StreamHandler {