- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 1,847 for closeFD (0.2 sec)
-
android/guava/src/com/google/common/io/ByteSink.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 28 20:13:02 UTC 2023 - 5.5K bytes - Viewed (0) -
guava/src/com/google/common/io/ByteSink.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 28 20:13:02 UTC 2023 - 5.5K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/internal/service/scopes/DefaultGradleUserHomeScopeServiceRegistryTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:34:44 UTC 2024 - 8K bytes - Viewed (0) -
src/net/http/transport_internal_test.go
t.Errorf("roundTrip = %#v, %v; want errServerClosedIdle, transportReadFromServerError, or nothingWrittenError", err, err) } <-pc.closech err = pc.closed if !isNothingWrittenError(err) && !isTransportReadFromServerError(err) && err != errServerClosedIdle { t.Errorf("pc.closed = %#v, %v; want errServerClosedIdle or transportReadFromServerError, or nothingWrittenError", err, err) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 15:57:17 UTC 2024 - 6.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
* * <pre>{@code * FluentFuture<UserName> userName = * ClosingFuture.submit( * closer -> closer.eventuallyClose(database.newTransaction(), closingExecutor), * executor) * .transformAsync((closer, transaction) -> transaction.queryClosingFuture("..."), executor) * .transform((closer, result) -> result.get("userName"), directExecutor())
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 98.3K bytes - Viewed (0) -
src/net/http/fcgi/fcgi_test.go
return len(buf), nil } func (rc *signalingNopWriteCloser) Close() error { close(rc.closed) return rc.ReadCloser.Close() } // Test whether server properly closes connection when processing slow // requests func TestSlowRequest(t *testing.T) { pr, pw := io.Pipe() writerDone := make(chan struct{}) go func() { for _, buf := range [][]byte{ streamBeginTypeStdin,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jul 11 18:51:39 UTC 2023 - 10.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ClosingFuture.java
* * <pre>{@code * FluentFuture<UserName> userName = * ClosingFuture.submit( * closer -> closer.eventuallyClose(database.newTransaction(), closingExecutor), * executor) * .transformAsync((closer, transaction) -> transaction.queryClosingFuture("..."), executor) * .transform((closer, result) -> result.get("userName"), directExecutor())
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 98.7K bytes - Viewed (0) -
android/guava/src/com/google/common/io/Closeables.java
* * @param inputStream the input stream to be closed, or {@code null} in which case this method * does nothing * @since 17.0 */ public static void closeQuietly(@CheckForNull InputStream inputStream) { try { close(inputStream, true); } catch (IOException impossible) { throw new AssertionError(impossible); } } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 17 14:35:11 UTC 2023 - 4.7K bytes - Viewed (0) -
guava/src/com/google/common/io/CharSource.java
checkNotNull(sink); Closer closer = Closer.create(); try { Reader reader = closer.register(openStream()); Writer writer = closer.register(sink.openStream()); return CharStreams.copy(reader, writer); } catch (Throwable e) { throw closer.rethrow(e); } finally { closer.close(); } } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 17 14:35:11 UTC 2023 - 25.1K bytes - Viewed (0) -
src/os/file_mutex_plan9.go
// readUnlock removes a reference from the file and unlocks it for reading. // It also closes the file if it marked as closed and there is no remaining // reference. func (file *file) readUnlock() { if file.fdmu.ReadUnlock() { file.destroy() } } // writeLock adds a reference to the file and locks it for writing. // It returns an error if the file is already closed. func (file *file) writeLock() error { if !file.fdmu.WriteLock() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Oct 08 03:57:40 UTC 2022 - 1.8K bytes - Viewed (0)