docs: @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));
              }
          });
      }