docs: @CheckReturnValue
      public Flowable<E> flowable() {
          return new Flowable<E>() {
              @Override
              protected void subscribeActual(Subscriber<? super E> s) {
                  s.onSubscribe(new QuerySubscription<>(ReactiveResult.this, s));
              }
          };
      }