- Sort Score
- Result 10 results
- Languages All
Results 541 - 550 of 1,049 for closes (0.04 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt
stream = http2Connection.newStream(requestHeaders, hasRequestBody) // We may have been asked to cancel while creating the new stream and sending the request // headers, but there was still no stream to close. if (canceled) { stream!!.closeLater(ErrorCode.CANCEL) throw IOException("Canceled") } stream!!.readTimeout().timeout(chain.readTimeoutMillis.toLong(), TimeUnit.MILLISECONDS)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Jul 29 21:11:09 UTC 2025 - 7K bytes - Viewed (0) -
docs/hotfixes.md
``` commit 4f3317effea38c203c358af9cb5ce3c0e4173976 Author: Klaus Post <******@****.***> Date: Mon Nov 8 08:41:27 2021 -0800 Close stream on panic (#13605) Always close streamHTTPResponse on panic on main thread to avoid write/flush after response handler has returned. ``` ``` Îģ git cherry-pick 4f3317effea38c203c358af9cb5ce3c0e4173976 ```
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Feb 14 21:36:02 UTC 2024 - 5K bytes - Viewed (0) -
fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/service/impl/OpenSearchDataServiceTest.java
super.setUp(); } @Override public void tearDown() throws Exception { super.tearDown(); // close runner runner.close(); // delete all files runner.clean(); } public void test_insert_deleteTx() { final OpenSearchAccessResult accessResult1 = new OpenSearchAccessResult();
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sat Mar 15 06:52:00 UTC 2025 - 6.8K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/WebSocketListener.kt
*/ open fun onClosed( webSocket: WebSocket, code: Int, reason: String, ) { } /** * Invoked when a web socket has been closed due to an error reading from or writing to the * network. Both outgoing and incoming messages may have been lost. No further calls to this * listener will be made. */ open fun onFailure( webSocket: WebSocket,
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 2K bytes - Viewed (0) -
src/main/java/jcifs/SmbPipeResource.java
/** * Gets the type of this pipe. * * @return the type of the pipe */ int getPipeType(); /** * Create a pipe handle * * @return pipe handle, needs to be closed when finished */ SmbPipeHandle openPipe();
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/WebFsIndexHelper.java
final OpenSearchUrlFilterService urlFilterService = ComponentUtil.getComponent(OpenSearchUrlFilterService.class); final OpenSearchUrlQueueService urlQueueService = ComponentUtil.getComponent(OpenSearchUrlQueueService.class); final OpenSearchDataService dataService = ComponentUtil.getComponent(OpenSearchDataService.class); try { // clear url filter urlFilterService.delete(sid);
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 24.9K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/ExternalHttp2Example.kt
var line: String? while (response.body .source() .readUtf8Line() .also { line = it } != null ) { println(line) } } finally { response.body.close() } client.connectionPool.evictAll() }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 1.4K bytes - Viewed (0) -
docs/em/docs/tutorial/dependencies/dependencies-with-yield.md
FastAPI đâđĻē đ đ <abbr title='sometimes also called "exit", "cleanup", "teardown", "close", "context managers", ...'>â đ âŽī¸ đ</abbr>. đ, âī¸ `yield` âŠī¸ `return`, & â â đ âŽī¸. /// tip â đ âī¸ `yield` 1ī¸âŖ đ đ°. /// /// note | đĄ âš đ đĸ đ â âī¸ âŽī¸: * <a href="https://docs.python.org/3/library/contextlib.html#contextlib.contextmanager" class="external-link" target="_blank">`@contextlib.contextmanager`</a> âī¸
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Mon Nov 18 02:25:44 UTC 2024 - 8.4K bytes - Viewed (0) -
cmd/admin-handlers.go
if err != nil { bugLogIf(ctx, stream.AddError(err.Error())) return } addErr = func(msg string) { inspectZipW.Close() encStream.Close() stream.AddError(msg) } defer encStream.Close() inspectZipW = zip.NewWriter(encStream) defer inspectZipW.Close() } else { // Legacy: Remove if we stop supporting inspection without public key. var key [32]byte
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 99.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/TestThread.java
} /** * Causes this thread to call the named method, and asserts that the call throws the expected type * of throwable. */ public void callAndAssertThrows( Class<? extends Throwable> expected, String methodName, Object... arguments) throws Exception { checkNotNull(expected); checkNotNull(methodName); checkNotNull(arguments); sendRequest(methodName, arguments);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 10.8K bytes - Viewed (0)