- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 49 for eventListeners (0.04 sec)
-
okhttp-dnsoverhttps/src/test/java/okhttp3/dnsoverhttps/DnsOverHttpsTest.kt
private lateinit var dns: Dns private val cacheFs = FakeFileSystem() private val eventListener = RecordingEventListener() private val bootstrapClient = OkHttpClient .Builder() .protocols(listOf(Protocol.HTTP_2, Protocol.HTTP_1_1)) .eventListener(eventListener) .build() @BeforeEach fun setUp() { server.protocols = bootstrapClient.protocols
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 11.7K bytes - Viewed (0) -
okhttp-logging-interceptor/api/logging-interceptor.api
} public class okhttp3/logging/LoggingEventListener$Factory : okhttp3/EventListener$Factory { public fun <init> ()V public fun <init> (Lokhttp3/logging/HttpLoggingInterceptor$Logger;)V public synthetic fun <init> (Lokhttp3/logging/HttpLoggingInterceptor$Logger;ILkotlin/jvm/internal/DefaultConstructorMarker;)V public fun create (Lokhttp3/Call;)Lokhttp3/EventListener;
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Apr 06 09:14:38 UTC 2024 - 4.5K bytes - Viewed (0) -
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 Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 16 23:20:49 UTC 2020 - 6.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/RetryAndFollowUpInterceptor.kt
} closeActiveExchange = false call.eventListener.followUpDecision(call, response, null) return response } val followUpBody = followUp.body if (followUpBody != null && followUpBody.isOneShot()) { closeActiveExchange = false call.eventListener.followUpDecision(call, response, null) return response }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue May 27 14:58:02 UTC 2025 - 12.4K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceHttpTest.kt
@RegisterExtension val clientTestRule = OkHttpClientTestRule() private val eventListener = RecordingEventListener() private val listener = EventSourceRecorder() private var client = clientTestRule .newClientBuilder() .eventListenerFactory(clientTestRule.wrap(eventListener)) .build() @AfterEach fun after() { listener.assertExhausted() } @Test
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 11:47:47 UTC 2025 - 8.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-UtilJvm.kt
internal fun HttpUrl.canReuseConnectionFor(other: HttpUrl): Boolean = host == other.host && port == other.port && scheme == other.scheme internal fun EventListener.asFactory() = EventListener.Factory { this } /** * Reads until this is exhausted or the deadline has been reached. This is careful to not extend the * deadline if one exists already. */ @Throws(IOException::class)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 10.2K bytes - Viewed (0) -
docs/features/caching.md
// $0.05 worth of phone storage in 2020 maxSize = 50L * 1024L * 1024L // 50 MiB )) .build() ``` ## EventListener events Cache Events are exposed via the EventListener API. Typical scenarios are below. ### Cache Hit In the ideal scenario the cache can fulfill the request without any conditional call to the network.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 3.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Authenticator.kt
* [RFC 2817][1]. The HTTP CONNECT request that creates this tunnel connection is special: it * does not participate in any [interceptors][Interceptor] or [event listeners][EventListener]. It * doesn't include the motivating request's HTTP headers or even its full URL; only the target * server's hostname is sent to the proxy. *
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 5.5K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/CacheInterceptor.kt
val networkRequest = strategy.networkRequest val cacheResponse = strategy.cacheResponse cache?.trackResponse(strategy) val listener = (call as? RealCall)?.eventListener ?: EventListener.NONE if (cacheCandidate != null && cacheResponse == null) { // The cache candidate wasn't applicable. Close it. cacheCandidate.body.closeQuietly() }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 10.3K bytes - Viewed (0) -
okhttp/src/androidMain/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 Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Dec 30 23:28:56 UTC 2024 - 127.9K bytes - Viewed (0)