- Sort Score
- Result 10 results
- Languages All
Results 561 - 570 of 887 for closure (0.09 sec)
-
api/maven-api-cli/src/main/java/org/apache/maven/api/cli/Invoker.java
* if they need to perform cleanup operations.</p> * * @throws InvokerException if an error occurs while closing the {@link Invoker} */ @Override default void close() throws InvokerException {}
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Thu Oct 03 16:03:55 UTC 2024 - 2.7K bytes - Viewed (0) -
okhttp-android/src/main/baseline-prof.txt
HSPLokio/ForwardingSink;-><init>(Lokio/Sink;)V HSPLokio/ForwardingSink;->close()V HSPLokio/ForwardingSink;->write(Lokio/Buffer;J)V HSPLokio/ForwardingSource;-><init>(Lokio/Source;)V HSPLokio/ForwardingSource;->close()V HSPLokio/GzipSource;-><init>(Lokio/Source;)V HSPLokio/GzipSource;->checkEqual(Ljava/lang/String;II)V HSPLokio/GzipSource;->close()V HSPLokio/GzipSource;->read(Lokio/Buffer;J)J
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Mar 21 11:22:00 UTC 2022 - 127.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java
settableFutureClass = classReloader.loadClass(SettableFuture.class.getName()); } @Override protected void tearDown() throws Exception { classReloader.close(); Thread.currentThread().setContextClassLoader(oldClassLoader); System.clearProperty("guava.concurrent.generate_cancellation_cause"); } public void testCancel_notDoneNoInterrupt() throws Exception {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 6.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java
settableFutureClass = classReloader.loadClass(SettableFuture.class.getName()); } @Override protected void tearDown() throws Exception { classReloader.close(); Thread.currentThread().setContextClassLoader(oldClassLoader); System.clearProperty("guava.concurrent.generate_cancellation_cause"); } public void testCancel_notDoneNoInterrupt() throws Exception {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 6.1K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/entity/ResponseData.java
final RequestData requestData = new RequestData(); requestData.setMethod(method); requestData.setUrl(url); return requestData; } @Override public void close() throws IOException { if (isTemporaryFile) { FileUtil.deleteInBackground(responseBodyFile); } }
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Sat Oct 12 01:40:57 UTC 2024 - 5.8K bytes - Viewed (0) -
cmd/os_unix.go
fd, err = openFileWithFD(dirPath, os.O_RDONLY, 0o666) if err != nil { if osErrToFileErr(err) == errFileNotFound { return nil } return osErrToFileErr(err) } } defer syscall.Close(fd) bufp := direntPool.Get().(*[]byte) defer direntPool.Put(bufp) buf := *bufp boff := 0 // starting read position in buf nbuf := 0 // end valid data in buf for { if boff >= nbuf {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 9.3K bytes - Viewed (0) -
CHANGELOG.md
* Fix: Honor `RequestBody.isOneShot()` in `MultipartBody` * Fix in `okhttp-coroutines`: Don't leak response bodies in `executeAsync()`. We had a bug where we didn't call `Response.close()` if the coroutine was canceled before its response was returned. * Upgrade: [Okio 3.9.0][okio_3_9_0]. * Upgrade: [Kotlin 1.9.23][kotlin_1_9_23]. * Upgrade: [UnicodeĀ® IDNA 15.1.0][idna_15_1_0]
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Apr 18 01:31:39 UTC 2024 - 21.4K bytes - Viewed (1) -
docs/erasure/storage-class/README.md
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 15 23:04:20 UTC 2023 - 5.8K bytes - Viewed (0) -
docs/debugging/healing-bin/main.go
if strings.HasSuffix(file, ".zip") { var sz int64 f, err := os.Open(file) if err != nil { return err } if st, err := f.Stat(); err == nil { sz = st.Size() } defer f.Close() zr, err := zip.NewReader(f, sz) if err != nil { return err } for _, file := range zr.File { if !file.FileInfo().IsDir() && strings.HasSuffix(file.Name, ".healing.bin") { r, err := file.Open()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 3.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/ThreadInterruptTest.kt
val responseBody = response.body.byteStream() val buffer = ByteArray(1024) assertFailsWith<IOException> { while (responseBody.read(buffer) != -1) { } } responseBody.close() } private fun sleep(delayMillis: Int) { try { Thread.sleep(delayMillis.toLong()) } catch (e: InterruptedException) { Thread.currentThread().interrupt() } }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 4.6K bytes - Viewed (0)