Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 33 for compute (0.18 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt

       *
       * The target execution time is implemented on a best-effort basis. If another task in this queue
       * is running when that time is reached, that task is allowed to complete before this task is
       * started. Similarly the task will be delayed if the host lacks compute resources.
       *
       * @throws RejectedExecutionException if the queue is shut down and the task is not cancelable.
       */
      fun schedule(
        task: Task,
    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)
  2. okhttp/src/main/kotlin/okhttp3/internal/connection/RouteSelector.kt

       */
      operator fun hasNext(): Boolean = hasNextProxy() || postponedRoutes.isNotEmpty()
    
      @Throws(IOException::class)
      operator fun next(): Selection {
        if (!hasNext()) throw NoSuchElementException()
    
        // Compute the next set of routes to attempt.
        val routes = mutableListOf<Route>()
        while (hasNextProxy()) {
          // Postponed routes are always tried last. For example, if we have 2 proxies and all the
    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)
  3. samples/compare/src/test/kotlin/okhttp3/compare/ApacheHttpClientTest.kt

     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp3.compare
    
    import assertk.assertThat
    import assertk.assertions.isEqualTo
    import assertk.assertions.startsWith
    import mockwebserver3.MockResponse
    import mockwebserver3.MockWebServer
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 2.1K bytes
    - Viewed (0)
  4. regression-test/src/androidTest/java/okhttp/regression/compare/ApacheHttpClientHttp2Test.kt

     * individuals on behalf of the Apache Software Foundation.  For more
     * information on the Apache Software Foundation, please see
     * <http://www.apache.org/>.
     *
     */
    package okhttp.regression.compare
    
    import org.apache.hc.client5.http.async.methods.SimpleHttpRequests
    import org.apache.hc.client5.http.async.methods.SimpleHttpResponse
    import org.apache.hc.client5.http.impl.async.HttpAsyncClients
    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)
  5. samples/compare/src/test/kotlin/okhttp3/compare/JavaHttpClientTest.kt

     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp3.compare
    
    import assertk.assertThat
    import assertk.assertions.isEqualTo
    import assertk.assertions.isNotNull
    import assertk.assertions.isNull
    import assertk.assertions.matches
    import java.net.http.HttpClient
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 2.7K bytes
    - Viewed (0)
  6. mockwebserver/README.md

    Use MockWebServer the same way that you use mocking frameworks like
    [Mockito](https://github.com/mockito/mockito):
    
    1. Script the mocks.
    2. Run application code.
    3. Verify that the expected requests were made.
    
    Here's a complete example:
    
    ```java
    public void test() throws Exception {
      // Create a MockWebServer. These are lean enough that you can create a new
      // instance for every unit test.
      MockWebServer server = new MockWebServer();
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Dec 17 15:34:10 GMT 2023
    - 5K bytes
    - Viewed (1)
  7. okhttp/src/test/java/okhttp3/ServerTruncatesRequestTest.kt

            )
            .hostnameVerifier(RecordingHostnameVerifier())
            .build()
        server.useHttps(handshakeCertificates.sslSocketFactory())
      }
    
      /** A request body that slowly trickles bytes, expecting to not complete. */
      private object SlowRequestBody : RequestBody() {
        override fun contentType(): MediaType? = null
    
        override fun writeTo(sink: BufferedSink) {
          for (i in 0 until 50) {
            sink.writeUtf8("abc")
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 9.5K bytes
    - Viewed (0)
  8. regression-test/src/androidTest/java/okhttp/regression/compare/AndroidHttpEngineTest.kt

     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp.regression.compare
    
    import android.net.http.ConnectionMigrationOptions
    import android.net.http.DnsOptions
    import android.net.http.HttpEngine
    import android.net.http.HttpException
    import android.net.http.QuicOptions
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Mar 24 13:19:43 GMT 2024
    - 6.2K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt

              connectResult = launchTcpConnect()
              nextTcpConnectAtNanos = now + connectDelayNanos
              awaitTimeoutNanos = connectDelayNanos
            }
    
            // Wait for an in-flight connect to complete or fail.
            if (connectResult == null) {
              connectResult = awaitTcpConnect(awaitTimeoutNanos, TimeUnit.NANOSECONDS) ?: continue
            }
    
            if (connectResult.isSuccess) {
    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)
  10. okhttp/src/main/kotlin/okhttp3/Call.kt

       * exception.
       *
       * @throws IllegalStateException when the call has already been executed.
       */
      fun enqueue(responseCallback: Callback)
    
      /** Cancels the request, if possible. Requests that are already complete cannot be canceled. */
      fun cancel()
    
      /**
       * Returns true if this call has been either [executed][execute] or [enqueued][enqueue]. It is an
       * error to execute a call more than once.
       */
    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)
Back to top