- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 60 for close (0.3 sec)
-
okhttp/src/test/java/okhttp3/EventListenerTest.kt
) var response = call.execute() assertThat(response.code).isEqualTo(200) response.close() listener.clearAllEvents() call = call.clone() response = call.execute() assertThat(response.code).isEqualTo(200) assertThat(response.body.string()).isEqualTo("abc") response.close() assertThat(listener.recordedEventTypes()).containsExactly( "CallStart", "CacheConditionalHit",
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 56.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt
while (!toClose.isEmpty()) { toClose.pop().close() } taskFaker.close() (filesystem.delegate as? FakeFileSystem)?.checkNoOpenFiles() } @ParameterizedTest @ArgumentsSource(FileSystemParamProvider::class) fun emptyCache(parameters: Pair<FileSystem, Boolean>) { setUp(parameters.first, parameters.second) cache.close() assertJournalEquals() }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Apr 15 14:55:09 GMT 2024 - 75.8K bytes - Viewed (0) -
src/main/java/org/codelibs/core/io/CopyUtil.java
try { return copyInternal(is, os); } finally { CloseableUtil.close(os); } } finally { CloseableUtil.close(is); } } /** * 指定されたエンコーディングのファイルからプラットフォームデフォルトエンコーディングのファイルへコピーします。 * * @param in
Java - Registered: Fri Apr 26 20:58:09 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 52.4K bytes - Viewed (0) -
cmd/xl-storage.go
if err != nil { w.Close() return err } if n != len(b) { w.Close() return io.ErrShortWrite } // Dealing with error returns from close() - 'man 2 close' // // A careful programmer will check the return value of close(), since it is quite possible that // errors on a previous write(2) operation are reported only on the final close() that releases
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
val source = stream.getSource() val out = stream.getSink().buffer() source.close() assertFailsWith<IOException> { source.read(Buffer(), 1) }.also { expected -> assertThat(expected.message).isEqualTo("stream closed") } out.writeUtf8("square") out.flush() out.close() assertThat(connection.openStreamCount()).isEqualTo(0)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
* * ```java * client.connectionPool().evictAll(); * ``` * * If your client has a cache, call [close()][Cache.close]. Note that it is an error to create calls * against a cache that is closed, and doing so will cause the call to crash. * * ```java * client.cache().close(); * ``` * * OkHttp also uses daemon threads for HTTP/2 connections. These will exit automatically if they * remain idle.
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 06 04:21:33 GMT 2024 - 52K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbFile.java
* {@inheritDoc} * * @see java.lang.AutoCloseable#close() */ @Override public synchronized void close () { SmbTreeHandleImpl th = this.treeHandle; if ( th != null ) { this.treeHandle = null; if ( this.transportContext.getConfig().isStrictResourceLifecycle() ) { th.close(); } } } /**
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Mon Mar 13 12:00:57 GMT 2023 - 81.6K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/modular_filesystem_test.cc
if (!status.ok()) GTEST_SKIP() << "Append() not supported: " << status; status = new_file->Flush(); if (!status.ok()) GTEST_SKIP() << "Flush() not supported: " << status; status = new_file->Close(); if (!status.ok()) GTEST_SKIP() << "Close() not supported: " << status; std::unique_ptr<ReadOnlyMemoryRegion> region; status = env_->NewReadOnlyMemoryRegionFromFile(filepath, ®ion);
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Fri May 27 20:25:58 GMT 2022 - 71K bytes - Viewed (0) -
src/archive/zip/reader_test.go
if size != ft.Size { t.Errorf("%v: uncompressed size %#x, want %#x", ft.Name, size, ft.Size) } r.Close() return } var b bytes.Buffer _, err = io.Copy(&b, r) if err != ft.ContentErr { t.Errorf("copying contents: %v (want %v)", err, ft.ContentErr) } if err != nil { return } r.Close() if g := uint64(b.Len()); g != size {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Mar 27 18:23:49 GMT 2024 - 55.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
} } // Avoid infinite recursion if a closeable's close() method throws RejectedExecutionException and // is closed using the direct executor. public void testCloseThrowsRejectedExecutionException() throws Exception { doThrow(new RejectedExecutionException()).when(mockCloseable).close(); ClosingFuture<Closeable> closingFuture = ClosingFuture.submit(
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 75.3K bytes - Viewed (0)