Method call

src/Scanner.java:772–797

(final Object arg)

    opened_scanner =
      new Callback<Deferred<ArrayList<ArrayList<KeyValue>>>, Object>() {
          public Deferred<ArrayList<ArrayList<KeyValue>>> call(final Object arg) {
            final Response resp;
            if (arg instanceof Long) {
              scanner_id = (Long) arg;
              resp = null;
            } else if (arg instanceof Response) {
              resp = (Response) arg;
              scanner_id = resp.scanner_id;
              scannerClosedOnServer = resp.scannerClosedOnServer;
              moreRows = resp.more;
            } else {
              throw new IllegalStateException("WTF? Scanner open callback"
                                              + " invoked with impossible"
                                              + " argument: " + arg);
            }
            if (LOG.isDebugEnabled()) {
              LOG.debug("Scanner " + Bytes.hex(scanner_id) + " opened on " + region);
            }
            if (resp != null) {
              if (resp.rows == null) {
                return scanFinished(!resp.more);
              }
              return Deferred.fromResult(resp.rows);
            }
            return nextRows();  // Restart the call.
          }
          public String toString() {
            return "scanner opened";
          }