}
        }
        return -1;
    }

    /**
     * Gets the set of session IDs for all currently running processes.
     *
     * @return set of session IDs for running processes
     */
    public Set<String> getRunningSessionIdSet() {
        return runningProcessMap.keySet();
    }

    /**
     * Sets the timeout for process destruction.
     *

                });
            }
        }

    }

    /**
     * Sets the job runtime for the current thread.
     *
     * @param runtime the job runtime to set
     */
    public void setJobRuntime(final LaJobRuntime runtime) {
        jobRuntimeLocal.set(runtime);
    }

    /**
     * Gets the job runtime for the current thread.
     *
     * @return the job runtime for the current thread

            this.url = url;
            this.depth = depth;
        }

        /**
         * Gets the URL of this crawl request.
         *
         * @return the URL to be crawled
         */
        public String getUrl() {
            return url;
        }

        /**
         * Gets the depth of this crawl request in the crawling hierarchy.
         *
         * @return the crawling depth

        return this.auth.isPreferredMech(mechanism);
    }

    @Override
    public boolean isEstablished() {
        return this.isEstablished;
    }

    /**
     * Gets the server's NTLM challenge bytes.
     * @return the server's challenge
     */
    public byte[] getServerChallenge() {
        return this.serverChallenge;
    }

    @Override

    return value;
  }

  // Serialization helpers

  /** The size of byte array representation in bytes. */
  private static final int BYTES = Stats.BYTES * 2 + Double.SIZE / Byte.SIZE;

  /**
   * Gets a byte array representation of this instance.
   *
   * <p><b>Note:</b> No guarantees are made regarding stability of the representation between
   * versions.
   */
  public byte[] toByteArray() {

                .sorted((doc1, doc2) -> Float.compare(toFloat(doc2.get(scoreField)), toFloat(doc1.get(scoreField))))
                .toList();

        // Calculate offset based on documents not in main searcher's top results
        int offset = 0;
        for (int i = 0; i < windowSize / 2 && i < fusedDocs.size(); i++) {
            if (!mainSearcherIdSet.contains(fusedDocs.get(i).get(idField))) {
                offset++;
            }

    }
  }

  @VisibleForTesting
  Set<Subscriber> getSubscribersForTesting(Class<?> eventType) {
    return MoreObjects.firstNonNull(subscribers.get(eventType), ImmutableSet.<Subscriber>of());
  }

  /**
   * Gets an iterator representing an immutable snapshot of all subscribers to the given event at
   * the time this method is called.
   */
  Iterator<Subscriber> getSubscribers(Object event) {

    // A task should have been scheduled
    assertTrue(fakePool.hasNext());
    e.execute(intCounter);
    // Our executor hasn't run any tasks yet.
    assertEquals(0, totalCalls.get());
    fakePool.runAll();
    assertEquals(2, totalCalls.get());
    // Queue is empty so no runner should be scheduled.
    assertFalse(fakePool.hasNext());

    // Check that execute can be safely repeated
    e.execute(intCounter);

#### Blocking APIs

Blocking APIs are convenient because you get top-to-bottom procedural code without indirection. Network calls work like regular method calls: ask for data and it is returned. If the request fails, you get a stacktrace right where the call was made.

            logger.error("Error setting filter config", e);
        }
    }

    /**
     * Gets the filter configuration.
     * @return the filter configuration or null
     */
    public FilterConfig getFilterConfig() {
        return null;
    }