- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 1,595 for closedc (1.36 sec)
-
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) -
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) -
platforms/core-configuration/model-core/src/main/java/org/gradle/model/internal/core/DefaultModelViewState.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Sep 28 09:51:04 UTC 2023 - 2.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) -
android/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 - 22.4K bytes - Viewed (0) -
src/net/textproto/writer.go
w.closeDot() fmt.Fprintf(w.W, format, args...) w.W.Write(crnl) return w.W.Flush() } // DotWriter returns a writer that can be used to write a dot-encoding to w. // It takes care of inserting leading dots when necessary, // translating line-ending \n into \r\n, and adding the final .\r\n line // when the DotWriter is closed. The caller should close the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 2.5K bytes - Viewed (0) -
src/crypto/cipher/io.go
if n != len(src) && err == nil { // should never happen err = io.ErrShortWrite } return } // Close closes the underlying Writer and returns its Close return value, if the Writer // is also an io.Closer. Otherwise it returns nil. func (w StreamWriter) Close() error { if c, ok := w.W.(io.Closer); ok { return c.Close() } return nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 13 17:09:47 UTC 2023 - 1.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
) { check(!closed) { "closed" } checkOffsetAndCount(source.size, 0, byteCount) sink.write(source, byteCount) } override fun flush() { if (closed) return // Don't throw; this stream might have been closed on the caller's behalf. sink.flush() } override fun close() { if (closed) return closed = true detachTimeout(timeout)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 16.2K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/continuous/CancellationContinuousIntegrationTest.groovy
then: cancelsAndExits() } def "should cancel build when System.in is closed"() { given: succeeds("build") when: gradle.stdinPipe.close() then: cancelsAndExits() } def "should cancel build when System.in contains some other characters, then closes"() { when: succeeds("build") stdinPipe << 'abc' then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 2.5K bytes - Viewed (0)