- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 3,379 for FClose (0.11 sec)
-
subprojects/core/src/test/groovy/org/gradle/util/internal/DisconnectableInputStreamTest.groovy
instr.close() } @Test void canReadUsingZeroLengthBuffer() { def instr = new DisconnectableInputStream(stream("abc"), toActionExecuter(executorFactory)) assertThat(instr.read(new byte[0], 0, 0), equalTo(0)) assertReads(instr, "abc") assertThat(instr.read(new byte[0], 0, 0), equalTo(-1)) instr.close() } @Test
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 07 08:18:46 UTC 2021 - 8.5K bytes - Viewed (0) -
src/net/fd_plan9.go
} return syscall.EPLAN9 } func (fd *netFD) Close() error { if err := fd.pfd.Close(); err != nil { return err } if !fd.ok() { return syscall.EINVAL } if fd.net == "tcp" { // The following line is required to unblock Reads. _, err := fd.ctl.WriteString("close") if err != nil { return err } } err := fd.ctl.Close() if fd.data != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 04 16:01:50 UTC 2018 - 3.6K bytes - Viewed (0) -
src/test/java/org/codelibs/core/io/CloseableUtilTest.java
Registered: Wed Jun 12 12:50:12 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 2.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ResponseBody.kt
* * `Response.body().close()` * * `Response.body().source().close()` * * `Response.body().charStream().close()` * * `Response.body().byteStream().close()` * * `Response.body().bytes()` * * `Response.body().string()` * * There is no benefit to invoking multiple `close()` methods for the same response body. * * For synchronous calls, the easiest way to make sure a response body is closed is with a `try`
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.7K 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) -
pilot/cmd/pilot-agent/status/ready/probe_test.go
g.Expect(probe.atleastOnceReady).Should(BeFalse()) server.Close() server = testserver.CreateAndStartServer(liveServerStats) probe.AdminPort = uint16(server.Listener.Addr().(*net.TCPAddr).Port) err = probe.Check() g.Expect(err).NotTo(HaveOccurred()) g.Expect(probe.atleastOnceReady).Should(BeTrue()) server.Close() server = testserver.CreateAndStartServer(noServerStats)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 5.9K bytes - Viewed (0) -
src/go/parser/testdata/chans.go2
func (s *Sender[T]) Send(v T) bool { select { case s.values <- v: return true case <-s.done: return false } } // Close tells the receiver that no more values will arrive. // After Close is called, the Sender may no longer be used. func (s *Sender[T]) Close() { close(s.values) } // A Receiver receives values from a Sender. type Receiver[T any] struct { values <-chan T done chan<- bool }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 24 19:44:06 UTC 2020 - 1.7K bytes - Viewed (0) -
src/net/http/httptest/server.go
func (s *Server) Close() { s.mu.Lock() if !s.closed { s.closed = true s.Listener.Close() s.Config.SetKeepAlivesEnabled(false) for c, st := range s.conns { // Force-close any idle connections (those between // requests) and new connections (those which connected // but never sent a request). StateNew connections are // super rare and have only been seen (in // previously-flaky tests) in the case of
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 10 17:26:10 UTC 2024 - 10.7K bytes - Viewed (0) -
test/typeparam/chans.go
case <-ctx.Done(): return false case s.values <- v: return true case <-s.done: return false } } // Close tells the receiver that no more values will arrive. // After Close is called, the _Sender may no longer be used. func (s *_Sender[Elem]) Close() { close(s.values) } // A _Receiver receives values from a _Sender. type _Receiver[Elem any] struct { values <-chan Elem
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 01 19:45:34 UTC 2022 - 8.4K bytes - Viewed (0) -
docs_src/dependencies/tutorial008.py
try: yield dep_a finally: dep_a.close() async def dependency_b(dep_a=Depends(dependency_a)): dep_b = generate_dep_b() try: yield dep_b finally: dep_b.close(dep_a) async def dependency_c(dep_b=Depends(dependency_b)): dep_c = generate_dep_c() try: yield dep_c finally:
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Mar 26 19:09:53 UTC 2020 - 455 bytes - Viewed (0)