- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for lose (0.02 sec)
-
docs/changelogs/changelog_3x.md
`Cache.urls()` would prevent in-flight entries from being written. ## Version 3.14.3 _2019-09-10_ * Fix: Don't lose HTTP/2 flow control bytes when incoming data races with a stream close. If this happened enough then eventually the connection would stall. * Fix: Acknowledge and apply inbound HTTP/2 settings atomically. Previously we had a race where we
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sun Feb 06 14:55:54 UTC 2022 - 50.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/reflect/TypeTokenTest.java
.testEquals(); } private interface Loser<E extends Throwable> { void lose() throws E; } public <T extends Loser<AssertionError>> void testMethod_exceptionTypes() throws NoSuchMethodException { Method failMethod = Loser.class.getMethod("lose"); Invokable<T, ?> invokable = new TypeToken<T>(getClass()) {}.method(failMethod);
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 18:44:53 UTC 2025 - 89K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt
* * ```java * client.connectionPool().evictAll(); * ``` * * If your client has a cache, call [close()][Cache.close]. Note that it is an error to create calls * against a cache that is closed, and doing so will cause the call to crash. * * ```java * client.cache().close(); * ``` * * OkHttp also uses daemon threads for HTTP/2 connections. These will exit automatically if they * remain idle.
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Oct 07 21:55:03 UTC 2025 - 51.4K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt
.url(server.url("/")) .build(), ).execute() .close() eventRecorder.removeUpToEvent<CallEnd>() val call = client.newCallWithListener( Request .Builder() .url(server.url("/")) .build(), ) val response = call.execute() response.close() assertThat(eventRecorder.recordedEventTypes()).containsExactly(
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Nov 05 18:28:35 UTC 2025 - 70.5K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/cache/DiskLruCacheTest.kt
createNewCache() } @AfterEach fun tearDown() { while (!toClose.isEmpty()) { toClose.pop().close() } taskFaker.close() (filesystem.delegate as? FakeFileSystem)?.checkNoOpenFiles() } @Test fun emptyCache() { cache.close() assertJournalEquals() } @Test fun recoverFromInitializationFailure() {
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sat Nov 01 12:18:11 UTC 2025 - 59.4K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbSessionImpl.java
} finally { super.finalize(); } } /** * {@inheritDoc} * * @see java.lang.AutoCloseable#close() */ @Override public void close() { release(); } /** * */ public void release() { long usage = this.usageCount.decrementAndGet();Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 68.9K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbFileIntegrationTest.java
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 56K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
logger.get().log(FINER, "cancelling {0}", this); boolean cancelled = future.cancel(mayInterruptIfRunning); if (cancelled) { close(); } return cancelled; } private void close() { logger.get().log(FINER, "closing {0}", this); closeables.close(); } private <U extends @Nullable Object> ClosingFuture<U> derive(FluentFuture<U> future) {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Sep 11 13:51:27 UTC 2025 - 96.9K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt
assertThat(c0e0.exchangeIndex).isEqualTo(0) val c0e1 = server.takeRequest() assertThat(c0e1.connectionIndex).isEqualTo(0) assertThat(c0e1.exchangeIndex).isEqualTo(1) response1.close() response2.close() } @Test fun connectionWindowUpdateAfterCanceling() { server.enqueue( MockResponse .Builder()
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sat Nov 01 12:18:11 UTC 2025 - 67.4K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt
@Timeout(5) @Tag("Slow") class Http2ConnectionTest { private val peer = MockHttp2Peer() private val taskFaker = TaskFaker() @AfterEach fun tearDown() { peer.close() taskFaker.close() } @Test fun serverPingsClientHttp2() { // Write the mocking script. peer.sendFrame().settings(Settings()) peer.acceptFrame() // ACK peer.sendFrame().ping(false, 2, 3)Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 75.5K bytes - Viewed (0)