Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 33 for State (0.16 sec)

  1. samples/slack/src/main/java/okhttp3/slack/SlackApi.java

      public HttpUrl authorizeUrl(String scopes, HttpUrl redirectUrl, ByteString state, String team) {
        HttpUrl.Builder builder = baseUrl.newBuilder("/oauth/authorize")
            .addQueryParameter("client_id", clientId)
            .addQueryParameter("scope", scopes)
            .addQueryParameter("redirect_uri", redirectUrl.toString())
            .addQueryParameter("state", state.base64());
    
        if (team != null) {
    Java
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Fri Jul 06 19:30:55 GMT 2018
    - 4.4K bytes
    - Viewed (1)
  2. docs/features/events.md

    This [sample factory](https://github.com/square/okhttp/blob/master/samples/guide/src/main/java/okhttp3/recipes/PrintEvents.java) creates a unique ID for each call and uses that ID to differentiate calls in log messages.
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Feb 06 02:19:09 GMT 2022
    - 7.7K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

        state = STATE_WRITING_REQUEST_BODY
        return ChunkedSink()
      }
    
      private fun newKnownLengthSink(): Sink {
        check(state == STATE_OPEN_REQUEST_BODY) { "state: $state" }
        state = STATE_WRITING_REQUEST_BODY
        return KnownLengthSink()
      }
    
      private fun newFixedLengthSource(length: Long): Source {
        check(state == STATE_OPEN_RESPONSE_BODY) { "state: $state" }
        state = STATE_READING_RESPONSE_BODY
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 16.2K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt

      internal val plansToCancel = CopyOnWriteArrayList<RoutePlanner.Plan>()
    
      override fun timeout(): Timeout = timeout
    
      @SuppressWarnings("CloneDoesntCallSuperClone") // We are a final type & this saves clearing state.
      override fun clone(): Call = RealCall(client, originalRequest, forWebSocket)
    
      override fun request(): Request = originalRequest
    
      /**
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 17.9K bytes
    - Viewed (2)
  5. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt

    import okio.BufferedSink
    import okio.BufferedSource
    
    /**
     * A connection to a remote web server capable of carrying 1 or more concurrent streams.
     *
     * Connections are shared in a connection pool. Accesses to the connection's state must be guarded
     * by holding a lock on the connection.
     */
    class RealConnection(
      val taskRunner: TaskRunner,
      val connectionPool: RealConnectionPool,
      override val route: Route,
      /** The low-level TCP socket. */
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 15.4K bytes
    - Viewed (0)
  6. docs/changelogs/changelog_4x.md

    _2022-06-12_
    
     *  Upgrade: [Kotlin 1.6.20][kotlin_1_6_20].
     *  Upgrade: [Okio 3.0.0][okio_3_0_0].
     *  Fix: Recover gracefully when Android's `NativeCrypto` crashes with `"ssl == null"`. This occurs
        when OkHttp retrieves ALPN state on a closed connection.
    
    
    ## Version 4.9.3
    
    _2021-11-21_
    
     *  Fix: Don't fail HTTP/2 responses if they complete before a `RST_STREAM` is sent.
    
    
    ## Version 4.9.2
    
    _2021-09-30_
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 17 13:25:31 GMT 2024
    - 25.2K bytes
    - Viewed (0)
  7. regression-test/src/main/AndroidManifest.xml

        package="okhttp.android.regression">
      <uses-permission android:name="android.permission.INTERNET" />
    
      <!-- For HttpEngine -->
      <uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />
    XML
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Mar 23 11:14:34 GMT 2024
    - 291 bytes
    - Viewed (0)
  8. docs/contribute/concurrency.md

    #### Http2Connection
    
    This lock guards internal state of each connection. This lock is never held for blocking operations. That means that we acquire the lock, read or write a few fields and release the lock. No I/O and no application-layer callbacks.
    
    #### Http2Stream
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Feb 06 16:35:36 GMT 2022
    - 7K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/connection/RouteSelector.kt

      private val connectionUser: ConnectionUser,
      private val fastFallback: Boolean,
    ) {
      // State for negotiating the next proxy to use.
      private var proxies = emptyList<Proxy>()
      private var nextProxyIndex: Int = 0
    
      // State for negotiating the next socket address to use.
      private var inetSocketAddresses = emptyList<InetSocketAddress>()
    
      // State for negotiating failed routes
      private val postponedRoutes = mutableListOf<Route>()
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Mar 06 17:33:38 GMT 2024
    - 7.2K bytes
    - Viewed (0)
  10. samples/slack/src/main/java/okhttp3/slack/OAuthSessionFactory.java

        if (mockWebServer == null) throw new IllegalStateException();
    
        ByteString state = randomToken();
        synchronized (this) {
          listeners.put(state, listener);
        }
    
        return slackApi.authorizeUrl(scopes, redirectUrl(), state, team);
      }
    
      private ByteString randomToken() {
        byte[] bytes = new byte[16];
        secureRandom.nextBytes(bytes);
    Java
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Aug 12 07:26:27 GMT 2021
    - 3.8K bytes
    - Viewed (0)
Back to top