shillelagh/src/main/java/shillelagh/Builder.java
public final Observable<T> toObservable() {
    if (!HAS_RX_JAVA) {
      throw new RuntimeException(
          "RxJava not available! Add RxJava to your build to use this feature");
    }

    return shillelagh.getObservable(tableObject, new CursorLoader() {
      @Override public Cursor getCursor() {
        return shillelagh.rawQuery(query.toString());
      }
    });
  }
public final Observable<T> toObservable() {
    if (!HAS_RX_JAVA) {
      throw new RuntimeException(
          "RxJava not available! Add RxJava to your build to use this feature");
    }

    return shillelagh.getObservable(tableObject, new CursorLoader() {
      @Override public Cursor getCursor() {
        return shillelagh.rawQuery(query.toString());
      }
    });
  }
public final Observable < T > toObservable ( ) { if ( ! HAS_RX_JAVA ) { throw new RuntimeException ( "RxJava not available! Add RxJava to your build to use this feature" ) ; } return shillelagh . getObservable ( tableObject , new CursorLoader ( ) { @ Override public Cursor getCursor ( ) { return shillelagh . rawQuery ( query . toString ( ) ) ; } } ) ; }
Executes a query and returns the results wrapped in an observable
Executes a query and returns the results wrapped in an observable