- Sort Score
- Result 10 results
- Languages All
Results 251 - 260 of 887 for closure (0.07 sec)
-
internal/grid/connection.go
return } } } }() // Close all active requests. if debugReqs { fmt.Println(c.String(), "Reconnected. Clearing outgoing.") } c.outgoing.Range(func(key uint64, client *muxClient) bool { client.close() return true }) c.inStream.Range(func(key uint64, value *muxServer) bool { value.close() return true }) c.inStream.Clear() c.outgoing.Clear()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 46.7K bytes - Viewed (0) -
scripts/playwright/header_param_models/image01.py
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Tue Sep 17 18:54:10 UTC 2024 - 1.1K bytes - Viewed (0) -
scripts/playwright/request_form_models/image01.py
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Fri Sep 13 09:14:46 UTC 2024 - 1.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/TestInputStream.java
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 2.5K bytes - Viewed (0) -
internal/http/listener_test.go
for _, serverAddr := range listener.Addrs() { conn, err := net.Dial("tcp", serverAddr.String()) if err != nil { t.Fatalf("Test %d: error: expected = <nil>, got = %v", i+1, err) } conn.Close() } listener.Close() } } func TestHTTPListenerAddr(t *testing.T) { if runtime.GOOS == "windows" { t.Skip() } nonLoopBackIP := getNonLoopBackIP(t) var casePorts []string
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 10 17:41:02 UTC 2024 - 11.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ConnectionReuseTest.kt
.url(server.url("/")) .header("Connection", "close") .build() val requestB = Request(server.url("/")) assertConnectionNotReused(requestA, requestB) } @Test fun connectionsAreNotReusedWithResponseConnectionClose() { server.enqueue( MockResponse( headers = headersOf("Connection", "close"), body = "a", ), )
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 12.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt
* hosting filesystem becomes unreachable, the iterator will omit elements rather than throwing * exceptions. * * **The caller must [close][Snapshot.close]** each snapshot returned by [Iterator.next]. Failing * to do so leaks open files! */ @Synchronized @Throws(IOException::class) fun snapshots(): MutableIterator<Snapshot> { initialize()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 34.7K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/CrawlerClientCreator.java
logger.info("{} is not available.", componentName); } if (client != null) { try { client.close(); } catch (final Exception ex) { logger.warn("Failed to close {}.", componentName, ex); } } } } public void setMaxClientFactorySize(final int maxClientFactorySize) {
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:47:32 UTC 2024 - 2.9K bytes - Viewed (0) -
fastapi/datastructures.py
""" return await super().seek(offset) async def close(self) -> None: """ Close the file. To be awaitable, compatible with async, this is run in threadpool. """ return await super().close() @classmethod def __get_validators__(cls: Type["UploadFile"]) -> Iterable[Callable[..., Any]]:
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Tue Apr 02 02:48:51 UTC 2024 - 5.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/ProcessHelper.java
new Thread(() -> { try { CloseableUtil.closeQuietly(process.getInputStream()); } catch (final Exception e) { logger.warn("Could not close a process input stream.", e); } finally { latch.countDown(); } }, "ProcessCloser-input-" + sessionId).start(); new Thread(() -> {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri Oct 11 21:20:39 UTC 2024 - 6.4K bytes - Viewed (0)