Anbdroid RxCursorLoader

RxCursor

Observable.create(new Observable.OnSubscribe<T>() {
   @Override public void call(Subscriber<? super T> subscriber) {
      final Cursor cursor = cursorLoader.getCursor();
      if (cursor.moveToFirst()) {
          while (!cursor.isAfterLast()) {
          if (!subscriber.isUnsubscribed()) {
            subscriber.onNext(cursor));
            cursor.moveToNext();
          }
        }
      }
      cursor.close();
      subscriber.onCompleted();
    }
  });
}