@CheckReturnValue
    public Flux<E> flux() {
        return Flux.from(new Publisher<E>() {
            @Override
            public void subscribe(Subscriber<? super E> s) {
                s.onSubscribe(new QuerySubscription<>(ReactorResult.this, s));
            }
        });
    }
@ CheckReturnValue public Flux < E > flux ( ) { return Flux . from ( new Publisher < E > ( ) { @ Override public void subscribe ( Subscriber < ? super E > s ) { s . onSubscribe ( new QuerySubscription < > ( ReactorResult . this , s ) ) ; } } ) ; }
Converts the result stream to a {@link Flux}.

@return stream of the results of this query.