code: @NonNull
      @CheckResult
      @Override
      public Flowable<Integer> asRxFlowable(@NonNull BackpressureStrategy backpressureStrategy) {
          return RxJavaUtils.createGetFlowable(storIOContentResolver, this, query, backpressureStrategy);
      }
docs: Creates "Hot" {@link Flowable} which will be subscribed to changes of tables from query
  and will emit result each time change occurs.
  <p>
  First result will be emitted immediately after subscription,
  other emissions will occur only if changes of tables from query will occur during lifetime of
  the {@link Flowable}.
  <dl>
  <dt><b>Scheduler:</b></dt>
  <dd>Operates on {@link StorIOContentResolver#defaultRxScheduler()} if not {@code null}.</dd>
  </dl>
  <p>
  Please don't forget to dispose from this {@link Flowable} because
  it's "Hot" and endless.
  
  @return non-null {@link Flowable} which will emit non-null
  number of results of the executed query and will be subscribed to changes of tables from query.