Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for getSink (0.3 sec)

  1. okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt

        val stream2 = connection.newStream(headerEntries("b", "banana"), true)
        connection.writePingAndAwaitPong() // Ensure the GO_AWAY that resets stream2 has been received.
        val sink1 = stream1.getSink().buffer()
        val sink2 = stream2.getSink().buffer()
        sink1.writeUtf8("abc")
        assertFailsWith<IOException> {
          sink2.writeUtf8("abc")
          sink2.flush()
        }.also { expected ->
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 75.4K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt

      /**
       * Returns a sink that can be used to write data to the peer.
       *
       * @throws IllegalStateException if this stream was initiated by the peer and a [writeHeaders] has
       *     not yet been sent.
       */
      fun getSink(): Sink {
        this.withLock {
          check(hasResponseHeaders || isLocallyInitiated) {
            "reply before requesting the sink"
          }
        }
        return sink
      }
    
      /**
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 23.2K bytes
    - Viewed (1)
  3. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

          }
          pushPromises(stream, request, response.pushPromises)
          if (body != null) {
            sleepNanos(bodyDelayNanos)
            val responseBodySink =
              stream.getSink().withThrottlingAndSocketPolicy(
                policy = response,
                disconnectHalfway = response.socketPolicy == DisconnectDuringResponseBody,
                expectedByteCount = body.contentLength,
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Mar 31 17:16:15 GMT 2024
    - 37.4K bytes
    - Viewed (0)
  4. build.gradle.kts

      configure<AnimalSnifferExtension> {
        annotation = "okhttp3.internal.SuppressSignatureCheck"
        sourceSets = listOf(project.sourceSets["main"])
      }
    
      val signature: Configuration by configurations.getting
      dependencies {
        // No dependency requirements for testing-support.
        if (project.name == "okhttp-testing-support") return@dependencies
    
        if (project.name == "mockwebserver3-junit5") {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Apr 18 01:32:42 GMT 2024
    - 8.9K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

        // Do blocking calls to plan a route for a new connection.
        val connect = planConnect()
    
        // Now that we have a set of IP addresses, make another attempt at getting a connection from
        // the pool. We have a better chance of matching thanks to connection coalescing.
        val pooled2 = planReusePooledConnection(connect, connect.routes)
        if (pooled2 != null) return pooled2
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 12K bytes
    - Viewed (0)
  6. okhttp/api/okhttp.api

    	public final fun check (Ljava/lang/String;[Ljava/security/cert/Certificate;)V
    	public fun equals (Ljava/lang/Object;)Z
    	public final fun findMatchingPins (Ljava/lang/String;)Ljava/util/List;
    	public final fun getPins ()Ljava/util/Set;
    	public fun hashCode ()I
    	public static final fun pin (Ljava/security/cert/Certificate;)Ljava/lang/String;
    	public static final fun sha1Hash (Ljava/security/cert/X509Certificate;)Lokio/ByteString;
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 15 13:41:01 GMT 2024
    - 70.2K bytes
    - Viewed (0)
Back to top