rxjava scroll database example by hibernate. (pity , JPA doesn't support scroll)

DataDao.java

  public Observable<Data> toObservable(int batch) {
    return Observable.create(new Observable.OnSubscribe<Data>() {
      @Override
      public void call(Subscriber<? super Data> subscriber) {
        Session session = ((Session) emp.get().getDelegate()).getSessionFactory().openSession();
        Query query = session.createQuery("select d from Data d order by id asc");
        query.setFetchSize(batch);
        query.setReadOnly(true);

        ScrollableResults results = query.scroll(ScrollMode.FORWARD_ONLY);
        while (results.next()) {
          Data data = (Data) results.get(0);
          subscriber.onNext(data);
        }

        results.close();
        session.close();

        if (!subscriber.isUnsubscribed()) {
          subscriber.onCompleted();
        }
      }
    });
  }

Shouldn't you check for (results.next() && !subscriber.isUnsubscribed()) ?