Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 41 for eventListener (0.12 sec)

  1. samples/guide/src/main/java/okhttp3/recipes/PrintEvents.java

        new PrintEvents().run();
      }
    
      private static final class PrintingEventListener extends EventListener {
        private static final Factory FACTORY = new Factory() {
          final AtomicLong nextCallId = new AtomicLong(1L);
    
          @Override public EventListener create(Call call) {
            long callId = nextCallId.getAndIncrement();
            System.out.printf("%04d %s%n", callId, call.request().url());
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 16 23:20:49 UTC 2020
    - 6.1K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/ConnectionCoalescingTest.kt

        val latch1 = CountDownLatch(1)
        val latch2 = CountDownLatch(1)
        val latch3 = CountDownLatch(1)
        val latch4 = CountDownLatch(1)
        val listener1: EventListener =
          object : EventListener() {
            override fun connectStart(
              call: Call,
              inetSocketAddress: InetSocketAddress,
              proxy: Proxy,
            ) {
              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)
  3. okhttp-android/src/main/baseline-prof.txt

    HSPLokhttp3/Dns;-><clinit>()V
    HSPLokhttp3/EventListener$Companion$NONE$1;-><init>()V
    HSPLokhttp3/EventListener;-><clinit>()V
    HSPLokhttp3/EventListener;-><init>()V
    HSPLokhttp3/EventListener;->callEnd(Lokhttp3/Call;)V
    HSPLokhttp3/EventListener;->callFailed(Lokhttp3/Call;Ljava/io/IOException;)V
    HSPLokhttp3/EventListener;->callStart(Lokhttp3/Call;)V
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Mar 21 11:22:00 UTC 2022
    - 127.9K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt

          failWebSocket(ProtocolException("Request header not permitted: 'Sec-WebSocket-Extensions'"))
          return
        }
    
        val webSocketClient =
          client.newBuilder()
            .eventListener(EventListener.NONE)
            .protocols(ONLY_HTTP1)
            .build()
        val request =
          originalRequest.newBuilder()
            .header("Upgrade", "websocket")
            .header("Connection", "Upgrade")
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 14:21:25 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  5. docs/changelogs/changelog_4x.md

            .sslSocketFactory(clientCertificates.sslSocketFactory(), clientCertificates.trustManager)
            .build()
        ```
    
     *  New: Add `cacheHit`, `cacheMiss`, and `cacheConditionalHit()` events to `EventListener`. Use
        these in logs, metrics, and even test cases to confirm your cache headers are configured as
        expected.
    
     *  New: Constant string `okhttp3.VERSION`. This is a string like "4.5.0-RC1", "4.5.0", or
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 17 13:25:31 UTC 2024
    - 25.2K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/JSSETest.kt

        val sessionIds = mutableListOf<String>()
    
        assumeNetwork()
    
        client =
          client.newBuilder()
            .eventListenerFactory(
              clientTestRule.wrap(
                object : EventListener() {
                  override fun connectionAcquired(
                    call: Call,
                    connection: Connection,
                  ) {
                    val sslSocket = connection.socket() as SSLSocket
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  7. docs/changelogs/upgrading_to_okhttp_4.md

              InetAddress.getAllByName(hostname).toList()
        })
        .build()
    ```
    
    SAM conversion impacts these APIs:
    
     * Authenticator
     * Dispatcher.setIdleCallback(Runnable)
     * Dns
     * EventListener.Factory
     * HttpLoggingInterceptor.Logger
     * LoggingEventListener.Factory
     * OkHttpClient.Builder.hostnameVerifier(HostnameVerifier)
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 16:58:16 UTC 2022
    - 10.9K bytes
    - Viewed (0)
  8. okhttp/api/okhttp.api

    	public abstract fun lookup (Ljava/lang/String;)Ljava/util/List;
    }
    
    public final class okhttp3/Dns$Companion {
    }
    
    public abstract class okhttp3/EventListener {
    	public static final field Companion Lokhttp3/EventListener$Companion;
    	public static final field NONE Lokhttp3/EventListener;
    	public fun <init> ()V
    	public fun cacheConditionalHit (Lokhttp3/Call;Lokhttp3/Response;)V
    	public fun cacheHit (Lokhttp3/Call;Lokhttp3/Response;)V
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 15 13:41:01 UTC 2024
    - 70.2K bytes
    - Viewed (0)
  9. okhttp-testing-support/src/main/kotlin/okhttp3/CallEvent.kt

    import java.io.IOException
    import java.net.InetAddress
    import java.net.InetSocketAddress
    import java.net.Proxy
    import okhttp3.internal.SuppressSignatureCheck
    
    /** Data classes that correspond to each of the methods of [EventListener]. */
    @SuppressSignatureCheck
    sealed class CallEvent {
      abstract val timestampNs: Long
      abstract val call: Call
    
      val name: String
        get() = javaClass.simpleName
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  10. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingEventListener.kt

    import org.junit.jupiter.api.Assertions.fail
    
    open class RecordingEventListener(
      /**
       * An override to ignore the normal order that is enforced.
       * EventListeners added by Interceptors will not see all events.
       */
      private val enforceOrder: Boolean = true,
    ) : EventListener() {
      val eventSequence: Deque<CallEvent> = ConcurrentLinkedDeque()
    
      private val forbiddenLocks = mutableListOf<Any>()
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 9K bytes
    - Viewed (0)
Back to top