code: private void processRow(Subscriber<? super T> subscriber) throws SQLException {
          checkSubscription(subscriber);
          if (!keepGoing)
              return;
          if (rs.next()) {
              log.trace("onNext");
              subscriber.onNext(function.call(rs));
          } else
              keepGoing = false;
      }
docs: Processes each row of the {@link ResultSet}.
  
  @param subscriber
  
  @throws SQLException