Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 501 for call$ (0.03 sec)

  1. okhttp/src/test/java/okhttp3/ConnectionCoalescingTest.kt

            .build()
        val request = Request.Builder().url(sanUrl).build()
        val call1 = client1.newCall(request)
        call1.enqueue(
          object : Callback {
            @Throws(IOException::class)
            override fun onResponse(
              call: Call,
              response: Response,
            ) {
              try {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/InterceptorTest.kt

            .build()
        val call = client.newCall(request1)
        assertFailsWith<SocketTimeoutException> {
          call.execute() // we want this call to throw a SocketTimeoutException
        }
      }
    
      @Test
      fun chainCanCancelCall() {
        val callRef = AtomicReference<Call>()
        val interceptor =
          Interceptor { chain: Interceptor.Chain ->
            val call = chain.call()
            callRef.set(call)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Jan 14 10:20:09 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/EventListener.kt

       *
       * This can be invoked more than 1 time for a single [Call]. For example, if the response
       * to the [Call.request] is a redirect to a different address.
       */
      open fun connectionAcquired(
        call: Call,
        connection: Connection,
      ) {
      }
    
      /**
       * Invoked after a connection has been released for the `call`.
       *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 15.2K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/internal/tls/ClientAuthTest.kt

        server.requestClientAuth()
        server.enqueue(
          MockResponse.Builder()
            .body("abc")
            .build(),
        )
        val call = client.newCall(Request.Builder().url(server.url("/")).build())
        val response = call.execute()
        assertThat(response.handshake!!.peerPrincipal)
          .isEqualTo(X500Principal("CN=Local Host"))
        assertThat(response.handshake!!.localPrincipal)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Jan 14 10:20:09 UTC 2024
    - 12.5K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/es/config/bsbhv/BsCrawlingInfoParamBhv.java

            return batchInsert(list, call, null);
        }
    
        public int[] batchInsert(List<CrawlingInfoParam> list, RequestOptionCall<BulkRequestBuilder> call,
                RequestOptionCall<IndexRequestBuilder> entityCall) {
            return doBatchInsert(new BulkList<>(list, call, entityCall), null);
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 9.8K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/es/config/bsbhv/BsPathMappingBhv.java

        public int[] batchInsert(List<PathMapping> list, RequestOptionCall<BulkRequestBuilder> call) {
            return batchInsert(list, call, null);
        }
    
        public int[] batchInsert(List<PathMapping> list, RequestOptionCall<BulkRequestBuilder> call,
                RequestOptionCall<IndexRequestBuilder> entityCall) {
            return doBatchInsert(new BulkList<>(list, call, entityCall), null);
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 9.8K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt

        }
        return result
      }
    
      /**
       * Remove this call from the connection's list of allocations. Returns a socket that the caller
       * should close.
       */
      internal fun releaseConnectionNoEvents(): Socket? {
        val connection = this.connection!!
        connection.lock.assertHeld()
    
        val calls = connection.calls
        val index = calls.indexOfFirst { it.get() == this@RealCall }
        check(index != -1)
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/es/config/bsbhv/BsScheduledJobBhv.java

        public int[] batchInsert(List<ScheduledJob> list, RequestOptionCall<BulkRequestBuilder> call) {
            return batchInsert(list, call, null);
        }
    
        public int[] batchInsert(List<ScheduledJob> list, RequestOptionCall<BulkRequestBuilder> call,
                RequestOptionCall<IndexRequestBuilder> entityCall) {
            return doBatchInsert(new BulkList<>(list, call, entityCall), null);
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  9. okhttp/src/test/java/okhttp3/DuplexTest.kt

            .url(server.url("/"))
            .post(AsyncRequestBody())
            .build()
        val call = client.newCall(request)
        call.timeout().timeout(250, TimeUnit.MILLISECONDS)
        assertFailsWith<IOException> {
          call.execute()
        }.also { expected ->
          assertThat(expected.message).isEqualTo("timeout")
          assertTrue(call.isCanceled())
        }
      }
    
      @Test
      fun fullCallTimeoutDoesNotApplyOnceConnected() {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 23.9K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/TimeLimiter.java

      /**
       * Returns an instance of {@code interfaceType} that delegates all method calls to the {@code
       * target} object, enforcing the specified time limit on each call. This time-limited delegation
       * is also performed for calls to {@link Object#equals}, {@link Object#hashCode}, and {@link
       * Object#toString}.
       *
       * <p>If the target method call finishes before the limit is reached, the return value or
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 15.3K bytes
    - Viewed (0)
Back to top