- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 259 for closing (0.04 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 31.8K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Response.kt
* An HTTP response. Instances of this class are not immutable: the response body is a one-shot * value that may be consumed only once and then closed. All other properties are immutable. * * This class implements [Closeable]. Closing it simply closes its response body. See * [ResponseBody] for an explanation and examples. */ class Response internal constructor( /**
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jul 28 14:39:28 UTC 2025 - 18.1K bytes - Viewed (0) -
src/archive/zip/writer_test.go
if err != nil { t.Fatalf("opening %s: %v", f.Name, err) } b, err := io.ReadAll(rc) if err != nil { t.Fatalf("reading %s: %v", f.Name, err) } err = rc.Close() if err != nil { t.Fatalf("closing %s: %v", f.Name, err) } if !bytes.Equal(b, wt.Data) { t.Errorf("File contents %q, want %q", b, wt.Data) } } func BenchmarkCompressedZipGarbage(b *testing.B) {
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Tue Jan 28 04:20:09 UTC 2025 - 14.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/maintenance/AdminMaintenanceAction.java
saveInfo(messages -> messages.addSuccessStartedDataUpdate(GLOBAL)); } return redirect(getClass()); } /** * Reloads the document index by closing and reopening it. * * @param form the action form (validated but not used for configuration) * @return HTML response redirecting to the maintenance page */ @Execute @Secured({ ROLE })
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 18K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Writer.kt
* if no streams were processed. * * @param lastGoodStreamId the last stream ID processed, or zero if no streams were processed. * @param errorCode reason for closing the connection. * @param debugData only valid for HTTP/2; opaque debug data to send. */ @Throws(IOException::class) fun goAway( lastGoodStreamId: Int, errorCode: ErrorCode,
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 11K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-UtilJvm.kt
try { close() } catch (e: AssertionError) { throw e } catch (rethrown: RuntimeException) { if (rethrown.message == "bio == null") { // Conscrypt in Android 10 and 11 may throw closing an SSLSocket. This is safe to ignore. // https://issuetracker.google.com/issues/177450597 return } throw rethrown } catch (_: Exception) { } }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 10.2K bytes - Viewed (1) -
src/test/java/jcifs/smb/DirFileEntryEnumIterator2Test.java
// Consume the only element assertTrue(it.hasNext()); assertSame(fe1, it.next()); // After exception path, iterator should be exhausted assertFalse(it.hasNext()); // Closing should send a single Smb2CloseRequest it.close(); verify(tree).send(argThat((Request<?> r) -> r instanceof Smb2CloseRequest)); } @Test
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 13.7K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/entity/ResponseData.java
} /** * Sets the response body from a file. * * @param responseBody the file containing the response body * @param isTemporary true if the file is temporary and should be deleted when closing */ public void setResponseBody(final File responseBody, final boolean isTemporary) { responseBodyFile = responseBody; isTemporaryFile = isTemporary; } /**
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 11.6K bytes - Viewed (0) -
src/test/java/jcifs/dcerpc/DcerpcHandleTest.java
} @Test @DisplayName("Should handle close operation") void testClose() throws IOException { // When: Closing handle handle.close(); // Then: Should complete without errors assertDoesNotThrow(() -> handle.close()); } @Test
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 15.3K bytes - Viewed (0) -
cmd/sftp-server-driver.go
switch { case len(w.buffer) > 0: err = errors.New("some file segments were not flushed from the queue") _ = w.w.CloseWithError(err) case w.err != nil: // No need to close here since both pipes were // closing inside TransferError() err = w.err default: err = w.w.Close() } for i := range w.buffer { delete(w.buffer, i) } w.wg.Wait() return err } type writerAt struct {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon Feb 10 16:35:49 UTC 2025 - 11.6K bytes - Viewed (0)