private fun requestIsOneShot(
    e: IOException,
    userRequest: Request,
  ): Boolean {
    val requestBody = userRequest.body
    return (requestBody != null && requestBody.isOneShot()) ||
      e is FileNotFoundException
  }

  private fun isRecoverable(
    e: IOException,
    requestSendStarted: Boolean,
  ): Boolean {
    // If there was a protocol problem, don't recover.
    if (e is ProtocolException) {

     * @return true if the stream contains valid sitemap data, false otherwise
     */
    protected boolean isValid(final InputStream in, final boolean recursive) {
        final BufferedInputStream bis = new BufferedInputStream(in);
        bis.mark(preloadSize);

        final byte[] bytes = new byte[preloadSize];
        try {
            if (bis.read(bytes) == -1) {
                return false;

        private byte[] rawPayload;

        // Response interface fields
        private boolean received = false;
        private int grantedCredits = 0;
        private int errorCode = 0;
        private boolean verifyFailed = false;
        private boolean error = false;
        private Exception exception;
        private Long expiration;

        public MockNotifyResponse(List<FileNotifyInformation> notifyInfo) {

        assertEquals(Boolean.TRUE, DocumentUtil.getValue(doc, "boolTrue", Boolean.class));

        doc.put("boolFalse", false);
        assertEquals(Boolean.FALSE, DocumentUtil.getValue(doc, "boolFalse", Boolean.class));

        doc.put("boolStr", "anything");
        assertEquals(Boolean.FALSE, DocumentUtil.getValue(doc, "boolStr", Boolean.class));
    }

    public void test_unsupported_type_conversion() {

        Boolean testValue = true;
        OptionalEntity<Boolean> result = OptionalUtil.ofNullable(testValue);

        assertNotNull(result);
        assertTrue(result.isPresent());
        assertEquals(Boolean.TRUE, result.get());
    }

    public void test_ofNullable_withFalseBoolean() {
        Boolean testValue = false;
        OptionalEntity<Boolean> result = OptionalUtil.ofNullable(testValue);

internal fun parseCookie(
  currentTimeMillis: Long,
  url: HttpUrl,
  setCookie: String,
): Cookie? = Cookie.parse(currentTimeMillis, url, setCookie)

internal fun cookieToString(
  cookie: Cookie,
  forObsoleteRfc2965: Boolean,
): String = cookie.toString(forObsoleteRfc2965)

internal fun addHeaderLenient(
  builder: Headers.Builder,
  line: String,
): Headers.Builder = builder.addLenient(line)

internal fun addHeaderLenient(

     * Not exactly sure what that is all about, certainly legacy stuff
     *
     * @return resolveHashes
     */
    boolean isResolveHashes();

    /**
     * Check if this referral needs to be resolved further
     *
     * @return whether this refrral needs to be resolved further
     */
    boolean isIntermediate();

    /**
     * Combine this referral with another to form a chain
     *

                  + listener
                  + " with executor "
                  + executor,
              e);
    }
  }

  @Override
  public boolean cancel(boolean mayInterruptIfRunning) {
    return false;
  }

  // TODO(lukes): Consider throwing InterruptedException when appropriate.
  @Override
  @ParametricNullness
  public V get() {
    return value;
  }

            return errorCode;
        }

        @Override
        public boolean verifySignature(byte[] buffer, int i, int size) {
            return true;
        }

        @Override
        public boolean isVerifyFailed() {
            return false;
        }

        @Override
        public boolean isError() {
            return errorCode != 0;
        }

        @Override

     */
    @NotThreadSafe
    class ProjectBuilderRequestBuilder {
        Session session;
        RequestTrace trace;
        Path path;
        Source source;
        boolean allowStubModel;
        boolean recursive;
        boolean processPlugins = true;
        List<RemoteRepository> repositories;

        ProjectBuilderRequestBuilder() {}

        /**
         * Sets the Maven session for this request.