- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 3,889 for close1 (0.13 sec)
-
src/os/pipe_test.go
t.Errorf("got %v, expected EOF or closed", err) } close(done) }() // Give the goroutine a chance to enter the Read // or Write call. This is sloppy but the test will // pass even if we close before the read/write. <-enteringRead time.Sleep(20 * time.Millisecond) if err := r.Close(); err != nil { t.Error(err) } // r.Close has completed, but since we assume r is in blocking mode that
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 05 23:35:29 UTC 2023 - 12.4K bytes - Viewed (0) -
src/net/http/requestwrite_test.go
} } } type closeChecker struct { io.Reader closed bool } func (rc *closeChecker) Close() error { rc.closed = true return nil } // TestRequestWriteClosesBody tests that Request.Write closes its request.Body. // It also indirectly tests NewRequest and that it doesn't wrap an existing Closer // inside a NopCloser, and that it serializes it correctly.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Sep 07 01:07:32 UTC 2022 - 23.3K bytes - Viewed (0) -
src/database/sql/fakedb_test.go
return s.placeholderConverter[idx] } func (s *fakeStmt) Close() error { if s.panic == "Close" { panic(s.panic) } if s.c == nil { panic("nil conn in fakeStmt.Close") } if s.c.db == nil { panic("in fakeStmt.Close, conn's db is nil (already closed)") } s.touchMem() if !s.closed { s.c.incrStat(&s.c.stmtsClosed) s.closed = true } if s.next != nil { s.next.Close() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 01 12:38:07 UTC 2024 - 30.3K bytes - Viewed (0) -
src/net/http/transport.go
if err == nil { panic("nil error") } pc.broken = true if pc.closed == nil { pc.closed = err pc.t.decConnsPerHost(pc.cacheKey) // Close HTTP/1 (pc.alt == nil) connection. // HTTP/2 closes its connection itself. if pc.alt == nil { if err != errCallerOwnsConn { pc.conn.Close() } close(pc.closech) } } pc.mutateHeaderFunc = nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 91K bytes - Viewed (0) -
internal/logger/logrotate.go
// Write is blocking otherwise. func (w *Writer) Write(p []byte) (n int, err error) { return w.pw.Write(p) } // Close closes the writer. // Any accepted writes will be flushed. Any new writes will be rejected. // Once Close() exits, files are synchronized to disk. func (w *Writer) Close() error { w.pw.CloseWithError(nil) if w.f != nil { if err := w.closeCurrentFile(); err != nil { return err } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.8K bytes - Viewed (0) -
.github/workflows/stale-pr.yml
It will be closed in 14 days if no further activity occurs. If you don't want the stale bot to close it, then set a milestone for it. days-before-pr-close: 14 close-pr-message: >
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 02 09:13:16 UTC 2024 - 1.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/AppendableWriterTest.java
Writer writer = new AppendableWriter(spy); writer.write("Hello"); assertFalse(spy.flushed); assertFalse(spy.closed); writer.flush(); assertTrue(spy.flushed); assertFalse(spy.closed); writer.close(); assertTrue(spy.flushed); assertTrue(spy.closed); } public void testCloseIsFinal() throws IOException { StringBuilder builder = new StringBuilder();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 3.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/wait_test.go
t.Errorf("Until did not return immediately when the stop chan was closed inside the func") } } func TestJitterUntil(t *testing.T) { ch := make(chan struct{}) // if a channel is closed JitterUntil never calls function f // and returns immediately close(ch) JitterUntil(func() { t.Fatal("should not have been invoked") }, 0, 1.0, true, ch) ch = make(chan struct{}) called := make(chan struct{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 41.1K bytes - Viewed (0) -
test/typeparam/chansimp.dir/a.go
// This will leave a goroutine running until either both channels are closed // or the context is canceled, at which point the returned channel is closed. func Merge[Elem any](ctx context.Context, c1, c2 <-chan Elem) <-chan Elem { r := make(chan Elem) go func(ctx context.Context, c1, c2 <-chan Elem, r chan<- Elem) { defer close(r) for c1 != nil || c2 != nil { select { case <-ctx.Done(): return
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jul 28 21:40:40 UTC 2021 - 5.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt
if (civilizedFileSystem) return fileSource lockingSourceCount++ return object : ForwardingSource(fileSource) { private var closed = false override fun close() { super.close() if (!closed) { closed = true synchronized(this@DiskLruCache) { lockingSourceCount-- if (lockingSourceCount == 0 && zombie) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 34.7K bytes - Viewed (0)