Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 76 for rake (0.31 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt

        request: Request,
        newRoutePlanner: Boolean,
        chain: RealInterceptorChain,
      ) {
        check(interceptorScopedExchange == null)
    
        this.withLock {
          check(!responseBodyOpen) {
            "cannot make a new request because the previous response is still open: " +
              "please call response.close()"
          }
          check(!requestBodyOpen)
        }
    
        if (newRoutePlanner) {
          val routePlanner =
    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)
  2. okhttp-tls/src/test/java/okhttp3/tls/internal/der/DerTest.kt

        val adapter = Adapters.NULL.withTag(tagClass = DerHeader.TAG_CLASS_PRIVATE, tag = 65_000L)
        assertThat(adapter.toDer(null)).isEqualTo(bytes)
        assertThat(adapter.fromDer(bytes)).isNull()
      }
    
      /** Make the claimed length of a nested object larger than the enclosing object. */
      @Test fun `large object inside small object`() {
        val bytes = "301b300d06092a864886f70d010101050003847fffffff000504030201".decodeHex()
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 31.7K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/HttpUrlTest.kt

      }
    
      @Test
      fun parseHostAsciiNonPrintable() {
        val host = "host\u0001"
        assertInvalid("http://$host/", "Invalid URL host: \"host\u0001\"")
        // TODO make exception message escape non-printable characters
      }
    
      @Test
      fun parseDoesNotTrimOtherWhitespaceCharacters() {
        // Whitespace characters list from Google's Guava team: http://goo.gl/IcR9RD
        // line tabulation
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 67.9K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/URLConnectionTest.kt

        )
        val response = getResponse(newRequest("/"))
        assertContent("This is the 2nd server!", response)
        assertThat(response.request.url).isEqualTo(
          server2.url("/"),
        )
    
        // make sure the first server was careful to recycle the connection
        assertContent("This is the first server again!", getResponse(Request(server.url("/"))))
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Jan 20 10:30:28 GMT 2024
    - 131.7K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt

          }
        }
      }
    
      /**
       * To make an HTTPS connection over an HTTP proxy, send an unencrypted CONNECT request to create
       * the proxy connection. This may need to be retried if the proxy requires authorization.
       */
      @Throws(IOException::class)
      private fun createTunnel(): Request? {
        var nextRequest = tunnelRequest!!
        // Make an SSL Tunnel on the first message pair of each SSL + proxy connection.
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 18.6K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/CallTest.kt

                throw AssertionError()
              }
            }
          },
        )
        val response = responseRef.take()
        assertThat(response.code).isEqualTo(200)
        assertThat(response.body.string()).isEqualTo("abc")
    
        // Make another request just to confirm that that connection can be reused...
        executeSynchronously("/").assertBody("def")
        // New connection.
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 10 19:46:48 GMT 2024
    - 142.5K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt

            taskRunner.kickCoordinator(this)
          }
        }
      }
    
      /**
       * Overload of [schedule] that uses a lambda for a repeating task.
       *
       * TODO: make this inline once this is fixed: https://github.com/oracle/graal/issues/3466
       */
      fun schedule(
        name: String,
        delayNanos: Long = 0L,
        block: () -> Long,
      ) {
        schedule(
          object : Task(name) {
    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)
  8. okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt

              }
            }
    
            val nextPlan = connectResult.nextPlan
            if (nextPlan != null) {
              // Try this plan's successor before deferred plans because it won the race!
              routePlanner.deferredPlans.addFirst(nextPlan)
            }
          }
        } finally {
          cancelInFlightConnects()
        }
    
        throw firstException!!
      }
    
      /**
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  9. mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt

        val data = ByteArray(1024 * 1024)
        var i = 0
        while (i < 1024) {
          try {
            out.write(data)
            out.flush()
            if (i == 513) {
              // pause slightly after halfway to make result more predictable
              Thread.sleep(100)
            }
          } catch (e: IOException) {
            break
          }
          i++
        }
        // Halfway +/- 0.5%
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 21.9K bytes
    - Viewed (0)
  10. android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt

    import org.junit.jupiter.api.Test
    import org.junit.jupiter.api.extension.RegisterExtension
    import org.opentest4j.TestAbortedException
    
    /**
     * Run with "./gradlew :android-test:connectedCheck -PandroidBuild=true" and make sure ANDROID_SDK_ROOT is set.
     */
    
    @Tag("Slow")
    class OkHttpTest {
      @Suppress("RedundantVisibilityModifier")
      @JvmField
      @RegisterExtension
      public val platform = PlatformRule()
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Jan 20 10:30:28 GMT 2024
    - 27K bytes
    - Viewed (1)
Back to top