- Sort Score
- Num 10 results
- Language All
Results 231 - 240 of 817 for closer (0.04 seconds)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/MessageInflater.kt
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sun Sep 21 06:26:07 GMT 2025 - 2.4K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/collect/TreeMultisetTest.java
assertEquals(Integer.MAX_VALUE, ms.headMultiset("b", CLOSED).size()); assertEquals(Integer.MAX_VALUE, ms.headMultiset("a", CLOSED).size()); assertEquals(3, ms.tailMultiset("c", CLOSED).size()); assertEquals(Integer.MAX_VALUE, ms.tailMultiset("b", CLOSED).size()); assertEquals(Integer.MAX_VALUE, ms.tailMultiset("a", CLOSED).size()); } @J2ktIncompatible
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 13K bytes - Click Count (0) -
src/archive/zip/example_test.go
if err != nil { log.Fatal(err) } } // Make sure to check the error on Close. err := w.Close() if err != nil { log.Fatal(err) } } func ExampleReader() { // Open a zip archive for reading. r, err := zip.OpenReader("testdata/readme.zip") if err != nil { log.Fatal(err) } defer r.Close() // Iterate through the files in the archive, // printing some of their contents.Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Wed Jan 27 00:22:03 GMT 2016 - 2K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt
} } internal fun useAsSocket() { javaNetSocket.soTimeout = 0 noNewExchanges() } override fun route(): Route = route override fun cancel() { // Close the raw socket so we don't end up doing synchronous I/O. rawSocket.closeQuietly() } override fun socket(): JavaNetSocket = javaNetSocket
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Oct 07 21:55:03 GMT 2025 - 14.6K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/FastFallbackTest.kt
url = serverIpv4 .url("/") .newBuilder() .host("localhost") .build() } @AfterEach internal fun tearDown() { serverIpv4.close() serverIpv6.close() } @Test fun callIpv6FirstEvenWhenIpv4IpIsListedFirst() { dnsResults = listOf( localhostIpv4, localhostIpv6, ) serverIpv4.enqueue(Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 10.6K bytes - Click Count (0) -
cmd/metacache-stream_test.go
w := newMetacacheWriter(&buf, 1<<20) defer w.Close() err := r.readFn(func(object metaCacheEntry) bool { err := w.write(object) if err != nil { t.Fatal(err) } return true }) r.Close() if err != io.EOF { t.Fatal(err) } err = w.Close() if err != nil { t.Fatal(err) } r = newMetacacheReader(&buf) defer r.Close() names, err := r.readNames(-1)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 15K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/SortedMultisets.java
return multiset().subMultiset(fromElement, CLOSED, toElement, OPEN).elementSet(); } @Override public SortedSet<E> headSet(@ParametricNullness E toElement) { return multiset().headMultiset(toElement, OPEN).elementSet(); } @Override public SortedSet<E> tailSet(@ParametricNullness E fromElement) { return multiset().tailMultiset(fromElement, CLOSED).elementSet(); } @Override
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 5.5K bytes - Click Count (0) -
guava-tests/test/com/google/common/collect/TreeMultisetTest.java
assertEquals(Integer.MAX_VALUE, ms.headMultiset("b", CLOSED).size()); assertEquals(Integer.MAX_VALUE, ms.headMultiset("a", CLOSED).size()); assertEquals(3, ms.tailMultiset("c", CLOSED).size()); assertEquals(Integer.MAX_VALUE, ms.tailMultiset("b", CLOSED).size()); assertEquals(Integer.MAX_VALUE, ms.tailMultiset("a", CLOSED).size()); } @J2ktIncompatible
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 13K bytes - Click Count (0) -
samples/guide/src/main/java/okhttp3/recipes/WebSocketEcho.java
System.out.println("MESSAGE: " + bytes.hex()); } @Override public void onClosing(WebSocket webSocket, int code, String reason) { webSocket.close(1000, null); System.out.println("CLOSE: " + code + " " + reason); } @Override public void onFailure(WebSocket webSocket, Throwable t, Response response) { t.printStackTrace(); } public static void main(String... args) { new WebSocketEcho().run(); }
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Thu Apr 04 11:40:21 GMT 2024 - 1.6K bytes - Click Count (0) -
internal/event/target/nats_contrib_test.go
Port: (xnet.Port(opts.Port)), IsPortSet: true, }, Subject: "test", } con, err := clientConfig.connectNats() if err != nil { t.Errorf("Could not connect to nats: %v", err) } defer con.Close() } func TestNatsConnUserPass(t *testing.T) { opts := natsserver.DefaultTestOptions opts.Port = 14223 opts.Username = "testminio" opts.Password = "miniotest" s := natsserver.RunServer(&opts)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Apr 27 04:30:57 GMT 2025 - 3K bytes - Click Count (0)