Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 1,192 for call$ (0.02 sec)

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

            .build(),
        )
        val call =
          client.newCall(
            Request.Builder()
              .url(server.url("/"))
              .build(),
          )
        call.enqueue(
          object : Callback {
            override fun onFailure(
              call: Call,
              e: IOException,
            ) {
            }
    
            override fun onResponse(
              call: Call,
              response: Response,
            ) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 56.9K bytes
    - Viewed (2)
  2. okhttp-logging-interceptor/api/logging-interceptor.api

    	public fun cacheConditionalHit (Lokhttp3/Call;Lokhttp3/Response;)V
    	public fun cacheHit (Lokhttp3/Call;Lokhttp3/Response;)V
    	public fun cacheMiss (Lokhttp3/Call;)V
    	public fun callEnd (Lokhttp3/Call;)V
    	public fun callFailed (Lokhttp3/Call;Ljava/io/IOException;)V
    	public fun callStart (Lokhttp3/Call;)V
    	public fun canceled (Lokhttp3/Call;)V
    	public fun connectEnd (Lokhttp3/Call;Ljava/net/InetSocketAddress;Ljava/net/Proxy;Lokhttp3/Protocol;)V
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 09:14:38 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  3. okhttp-testing-support/src/main/kotlin/okhttp3/ConnectionEvent.kt

        override val timestampNs: Long,
        val route: Route,
        val call: Call,
      ) : ConnectionEvent()
    
      data class ConnectFailed(
        override val timestampNs: Long,
        val route: Route,
        val call: Call,
        val exception: IOException,
      ) : ConnectionEvent() {
        override fun closes(event: ConnectionEvent): Boolean = event is ConnectStart && call == event.call && route == event.route
      }
    
      data class ConnectEnd(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  4. samples/guide/src/main/java/okhttp3/recipes/CancelCall.java

            .build();
    
        final long startNanos = System.nanoTime();
        final Call call = client.newCall(request);
    
        // Schedule a job to cancel the call in 1 second.
        executor.schedule(() -> {
          System.out.printf("%.2f Canceling call.%n", (System.nanoTime() - startNanos) / 1e9f);
          call.cancel();
          System.out.printf("%.2f Canceled call.%n", (System.nanoTime() - startNanos) / 1e9f);
        }, 1, TimeUnit.SECONDS);
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 12 03:31:36 UTC 2019
    - 2.1K bytes
    - Viewed (0)
  5. okhttp-sse/src/main/kotlin/okhttp3/sse/internal/RealEventSource.kt

    ) : EventSource, ServerSentEventReader.Callback, Callback {
      private var call: Call? = null
    
      @Volatile private var canceled = false
    
      fun connect(callFactory: Call.Factory) {
        call =
          callFactory.newCall(request).apply {
            enqueue(this@RealEventSource)
          }
      }
    
      override fun onResponse(
        call: Call,
        response: Response,
      ) {
        processResponse(response)
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  6. 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)
  7. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt

        }
      }
    
      override fun connectStart(
        route: Route,
        call: Call,
      ) = logEvent(ConnectionEvent.ConnectStart(System.nanoTime(), route, call))
    
      override fun connectFailed(
        route: Route,
        call: Call,
        failure: IOException,
      ) = logEvent(
        ConnectionEvent.ConnectFailed(System.nanoTime(), route, call, failure),
      )
    
      override fun connectEnd(
        connection: Connection,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  8. 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)
  9. okhttp/src/main/kotlin/okhttp3/internal/http/RealInterceptorChain.kt

        return copy(writeTimeoutMillis = checkDuration("writeTimeout", timeout.toLong(), unit))
      }
    
      override fun call(): Call = call
    
      override fun request(): Request = request
    
      @Throws(IOException::class)
      override fun proceed(request: Request): Response {
        check(index < interceptors.size)
    
        calls++
    
        if (exchange != null) {
          check(exchange.finder.routePlanner.sameHostAndPort(request.url)) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  10. 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)
Back to top