// Stream intercepts stream RPC requests
Stream intercepts stream RPC requests
// Stream intercepts stream RPC requests
func (interceptor *sqalxInterceptor) Stream() grpc.StreamServerInterceptor {
	return func(
		srv interface{},
		stream grpc.ServerStream,
		info *grpc.StreamServerInfo,
		handler grpc.StreamHandler,
	) error {
		newCtx := context.WithValue(stream.Context(), "SqalxNode", rootSqalxNode)
		wrapped := server.WrapServerStream(stream)
		wrapped.WrappedContext = newCtx
		return handler(srv, wrapped)
	}
}
func ( interceptor * sqalxInterceptor ) Stream ( ) grpc . StreamServerInterceptor { return func ( srv interface { } , stream grpc . ServerStream , info * grpc . StreamServerInfo , handler grpc . StreamHandler , ) error { newCtx := context . WithValue ( stream . Context ( ) , " " , rootSqalxNode ) wrapped := server . WrapServerStream ( stream ) wrapped . WrappedContext = newCtx return handler ( srv , wrapped ) } }
Stream intercepts stream RPC requests
Stream intercepts stream RPC requests