Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 53 for once (0.13 sec)

  1. okhttp-sse/src/main/kotlin/okhttp3/sse/EventSource.kt

       */
      fun cancel()
    
      fun interface Factory {
        /**
         * Creates a new event source and immediately returns it. Creating an event source initiates an
         * asynchronous process to connect the socket. Once that succeeds or fails, `listener` will be
         * notified. The caller must cancel the returned event source when it is no longer in use.
         */
        fun newEventSource(
          request: Request,
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 1.4K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt

              return block()
            }
          },
          delayNanos,
        )
      }
    
      /**
       * Executes [block] once on a task runner thread.
       *
       * TODO: make this inline once this is fixed: https://github.com/oracle/graal/issues/3466
       */
      fun execute(
        name: String,
        delayNanos: Long = 0L,
        cancelable: Boolean = true,
        block: () -> Unit,
      ) {
        schedule(
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/http/RealInterceptorChain.kt

            "network interceptor ${interceptors[index - 1]} must retain the same host and port"
          }
          check(calls == 1) {
            "network interceptor ${interceptors[index - 1]} must call proceed() exactly once"
          }
        }
    
        // Call the next interceptor in the chain.
        val next = copy(index = index + 1, request = request)
        val interceptor = interceptors[index]
    
        @Suppress("USELESS_ELVIS")
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/connection/Locks.kt

        contract { callsInPlace(action, InvocationKind.EXACTLY_ONCE) }
        return lock.withLock(action)
      }
    
      inline fun <T> RealConnection.withLock(action: () -> T): T {
        contract { callsInPlace(action, InvocationKind.EXACTLY_ONCE) }
        return lock.withLock(action)
      }
    
      inline fun <T> RealCall.withLock(action: () -> T): T {
        contract { callsInPlace(action, InvocationKind.EXACTLY_ONCE) }
        return lock.withLock(action)
      }
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 2.1K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/TestTls13Request.kt

        CipherSuite.TLS_AES_128_CCM_8_SHA256,
      )
    
    /**
     * A TLS 1.3 only Connection Spec. This will be eventually be exposed
     * as part of MODERN_TLS or folded into the default OkHttp client once published and
     * available in JDK11 or Conscrypt.
     */
    private val TLS_13 =
      ConnectionSpec.Builder(true)
        .cipherSuites(*TLS13_CIPHER_SUITES.toTypedArray())
        .tlsVersions(TlsVersion.TLS_1_3)
        .build()
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 3K bytes
    - Viewed (0)
  6. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/BasicDerAdapter.kt

      /** The tag class this adapter expects, or -1 to match any tag class. */
      val tagClass: Int,
      /** The tag this adapter expects, or -1 to match any tag. */
      val tag: Long,
      /** Encode and decode the value once tags are handled. */
      private val codec: Codec<T>,
      /** True if the default value should be used if this value is absent during decoding. */
      val isOptional: Boolean = false,
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 4.4K bytes
    - Viewed (0)
  7. docs/features/interceptors.md

    call to `chain.proceed(request)` is a critical part of each interceptor’s implementation. This simple-looking method is where all the HTTP work happens, producing a response to satisfy the request. If `chain.proceed(request)` is being called more than once previous response bodies must be closed.
    
    Interceptors can be chained. Suppose you have both a compressing interceptor and a checksumming interceptor: you'll need to decide whether data is compressed and then checksummed, or checksummed and...
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Feb 06 02:19:09 GMT 2022
    - 8.1K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/http/DateFormatting.kt

        "EEE dd-MMM-yy HH:mm:ss z",
        "EEE dd MMM yy HH:mm:ss z",
        "EEE,dd-MMM-yy HH:mm:ss z",
        "EEE,dd-MMM-yyyy HH:mm:ss z",
        "EEE, dd-MM-yyyy HH:mm:ss z",
        // RI bug 6641315 claims a cookie of this format was once served by www.yahoo.com:
        "EEE MMM d yyyy HH:mm:ss z",
      )
    
    private val BROWSER_COMPATIBLE_DATE_FORMATS =
      arrayOfNulls<DateFormat>(BROWSER_COMPATIBLE_DATE_FORMAT_STRINGS.size)
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 4.1K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/Call.kt

       * error to execute a call more than once.
       */
      fun isExecuted(): Boolean
    
      fun isCanceled(): Boolean
    
      /**
       * Returns a timeout that spans the entire call: resolving DNS, connecting, writing the request
       * body, server processing, and reading the response body. If the call requires redirects or
       * retries all must complete within one timeout period.
       *
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Dec 20 23:27:07 GMT 2023
    - 3.6K bytes
    - Viewed (0)
  10. regression-test/src/androidTest/java/okhttp/regression/compare/ApacheHttpClientHttp2Test.kt

    /*
     * ====================================================================
     * Licensed to the Apache Software Foundation (ASF) under one
     * or more contributor license agreements.  See the NOTICE file
     * distributed with this work for additional information
     * regarding copyright ownership.  The ASF licenses this file
     * to you under the Apache License, Version 2.0 (the
     * "License"); you may not use this file except in compliance
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 2.6K bytes
    - Viewed (0)
Back to top