code: @CheckReturnValue
      public Flowable<E> flowable() {
          return new Flowable<E>() {
              @Override
              protected void subscribeActual(Subscriber<? super E> s) {
                  s.onSubscribe(new QuerySubscription<>(ReactiveResult.this, s));
              }
          };
      }
docs: Converts the result stream to a {@link io.reactivex.Flowable}. When the flowable terminates
  this result instance will be closed.
  
  @return flowable stream of the results of this query.