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