func NewStreamServerInterceptor(arr ...grpc.StreamServerInterceptor) StreamServerInterceptor {
	return &streamServerInterceptor{
		interceptors: arr,
		lock:         &sync.RWMutex{},
	}
}
// NewStreamServerInterceptor returns a new `StreamServerInterceptor`.
// It initializes its interceptor chain with `arr`.
// This implementation is thread-safe.
NewStreamServerInterceptor returns a new `StreamServerInterceptor`.
It initializes its interceptor chain with `arr`.
This implementation is thread-safe.
// NewStreamServerInterceptor returns a new ` StreamServerInterceptor ` . // It initializes its interceptor chain with ` arr ` . // This implementation is thread - safe .
func NewStreamServerInterceptor(arr ...grpc.StreamServerInterceptor) StreamServerInterceptor {
	return &streamServerInterceptor{
		interceptors: arr,
		lock:         &sync.RWMutex{},
	}
}
func NewStreamServerInterceptor ( arr ... grpc . StreamServerInterceptor ) StreamServerInterceptor { return & streamServerInterceptor { interceptors : arr , lock : & sync . RWMutex { } , } }
NewStreamServerInterceptor returns a new `StreamServerInterceptor`.
NewStreamServerInterceptor returns a new ` StreamServerInterceptor ` .