if (responseData == null || !responseData.hasResponseBody()) {
            throw new CrawlingAccessException("No response body.");
        }

        final ExtractorFactory extractorFactory = crawlerContainer.getComponent("extractorFactory");
        if (extractorFactory == null) {
            throw new CrawlerSystemException("Could not find extractorFactory.");
        }

    private int epoch;

    /**
     * Create a new lease V2 context request
     */
    public LeaseV2CreateContextRequest() {
        this.leaseKey = new Smb2LeaseKey();
        this.parentLeaseKey = new Smb2LeaseKey(new byte[16]); // Zero parent key by default
        this.leaseState = 0;
        this.leaseFlags = 0;
        this.epoch = 1;
    }

    /**
     * Create a new lease V2 context request with specified parameters

  public Collection<V> get(@ParametricNullness K key) {
    if (keyPredicate.apply(key)) {
      return unfiltered.get(key);
    } else if (unfiltered instanceof SetMultimap) {
      return new AddRejectingSet<>(key);
    } else {
      return new AddRejectingList<>(key);
    }
  }

  private static final class AddRejectingSet<K extends @Nullable Object, V extends @Nullable Object>
      extends ForwardingSet<V> {

	// Managed values.
	val          atomic.Pointer[T]
	lastUpdateMs atomic.Int64
	updating     sync.Mutex
}

// New allocates a new cached value instance. Tt must be initialized with
// `.TnitOnce`.
func New[T any]() *Cache[T] {
	return &Cache[T]{}
}

// NewFromFunc allocates a new cached value instance and initializes it with an
// update function, making it ready for use.

        if (servers == null) {
            servers = new ArrayList<>();
        }

        return servers;
    }

    public ArtifactResolutionRequest setMirrors(List<Mirror> mirrors) {
        this.mirrors = mirrors;

        return this;
    }

    public List<Mirror> getMirrors() {
        if (mirrors == null) {
            mirrors = new ArrayList<>();
        }

        return mirrors;

    }

    public void addArtifact(Artifact artifact) {
        if (artifacts == null) {
            artifacts = new LinkedHashSet<>();
        }

        artifacts.add(artifact);
    }

    public Set<Artifact> getArtifacts() {
        if (artifacts == null) {
            artifacts = new LinkedHashSet<>();
        }

        return artifacts;
    }

    public void setArtifacts(Set<Artifact> artifacts) {

    HasBoth hasBoth = new HasBoth();
    FluentIterable<TypeA> alist =
        FluentIterable.from(asList(new TypeA(), new TypeA(), hasBoth, new TypeA()));
    Iterable<TypeB> blist = alist.filter(TypeB.class);
    assertThat(blist).containsExactly(hasBoth).inOrder();
  }

  public void testAnyMatch() {
    ArrayList<String> list = new ArrayList<>();

 *
 * <p>Usage examples:</p>
 * <pre>
 *     throw new CurlException("Error message");
 *     throw new CurlException("Error message", cause);
 * </pre>
 *
 * @see RuntimeException
 */
public class CurlException extends RuntimeException {

    private static final long serialVersionUID = 1L;

    /**
     * Constructs a new CurlException with the specified detail message and cause.
     *

    /**
     * Constructs a new TransportException with no detail message.
     */
    public TransportException() {
    }

    /**
     * Constructs a new TransportException with the specified detail message.
     * @param msg the detail message
     */
    public TransportException(final String msg) {
        super(msg);
    }

    /**
     * Constructs a new TransportException with the specified cause.

/**
 * @author shinsuke
 *
 */
public class AbstractCrawlerClientTest extends PlainTestCase {

    public void test_checkMaxContentLength() {
        AbstractCrawlerClient client = new AbstractCrawlerClient() {
        };
        ResponseData responseData = new ResponseData();
        responseData.setUrl("http://test.com/");

        client.checkMaxContentLength(responseData);

        responseData.setContentLength(-1);