- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 3,379 for FClose (0.18 sec)
-
internal/s3select/json/preader.go
dstRec.SelectFormat = sql.SelectFmtJSON return dstRec, nil } // Close - closes underlying reader. func (r *PReader) Close() error { if r.close != nil { close(r.close) r.readerWg.Wait() r.close = nil } r.recordsRead = len(r.current) if r.err == nil { r.err = io.EOF } return r.readCloser.Close() } // nextSplit will attempt to skip a number of bytes and
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Mar 05 04:57:35 UTC 2023 - 6.4K bytes - Viewed (0) -
.github/workflows/stale.yml
permissions: contents: read jobs: stale: permissions: issues: write # for actions/stale to close stale issues pull-requests: write # for actions/stale to close stale PRs runs-on: ubuntu-latest env: ACTIONS_STEP_DEBUG: true steps: - name: Close Stale Issues uses: actions/stale@v8 with: repo-token: ${{ secrets.GITHUB_TOKEN }}
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Tue Apr 11 02:27:05 UTC 2023 - 972 bytes - Viewed (0) -
src/net/timeout_test.go
// Ensure that our background Dial returns before we close the listener. // Otherwise, the listener's port could be reused immediately and we // might spuriously Dial some completely unrelated socket, causing some // other test to see an unexpected extra connection. defer func() { cancel() <-dialDone }() go func() { defer close(dialDone) d := Dialer{}
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 18:06:55 UTC 2024 - 30K bytes - Viewed (0) -
tests/test_ws_router.py
await websocket.accept() await websocket.send_text("Hello, world!") await websocket.close() @router.websocket_route("/router") async def routerindex(websocket: WebSocket): await websocket.accept() await websocket.send_text("Hello, router!") await websocket.close() @prefix_router.websocket_route("/") async def routerprefixindex(websocket: WebSocket):
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sun Jun 11 19:08:14 UTC 2023 - 7.5K bytes - Viewed (0) -
src/net/mockserver_test.go
go func() { handler(ls, ls.Listener) close(ls.done) }() return nil } func (ls *localServer) teardown() error { ls.lnmu.Lock() defer ls.lnmu.Unlock() if ls.Listener != nil { network := ls.Listener.Addr().Network() address := ls.Listener.Addr().String() ls.Listener.Close() for _, c := range ls.cl { if err := c.Close(); err != nil { return err } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 13.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/CloseablesTest.java
import java.io.Reader; import junit.framework.TestCase; /** * Unit tests for {@link Closeables}. * * <p>Checks proper closing behavior, and ensures that IOExceptions on Closeable.close() are not * propagated out from the {@link Closeables#close} method if {@code swallowException} is true. * * @author Michael Lancaster */ public class CloseablesTest extends TestCase { private Closeable mockCloseable;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/CloserTest.java
} public void testNullCloseable() throws IOException { Closer closer = Closer.create(); closer.register(null); closer.close(); } /** * Asserts that an exception was thrown when trying to close each of the given throwables and that * each such exception was suppressed because of the given thrown exception. */ private void assertSuppressed(Suppression... expected) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 15:26:58 UTC 2024 - 11.8K bytes - Viewed (0) -
src/compress/flate/deflate_test.go
t.Fatalf("NewWriter: %v", err) } closeErr := zw.Close() flushErr := zw.Flush() _, writeErr := zw.Write([]byte("Test")) checkErrors([]error{closeErr, flushErr, writeErr}, errIO, t) // After closing writer we should persistent "write after close" error across Flush and Write calls, but return nil // on next Close calls. var b bytes.Buffer zw.Reset(&b) err = zw.Close() if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 14 00:03:57 UTC 2023 - 25.6K bytes - Viewed (0) -
test/typeparam/chansimp.dir/main.go
go func() { c <- 4 c <- 2 c <- 5 close(c) }() got := a.ReadAll(context.Background(), c) want := []int{4, 2, 5} if !a.SliceEqual(got, want) { panic(fmt.Sprintf("ReadAll returned %v, want %v", got, want)) } } func TestMerge() { c1 := make(chan int) c2 := make(chan int) go func() { c1 <- 1 c1 <- 3 c1 <- 5 close(c1) }() go func() { c2 <- 2 c2 <- 4
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 24 02:14:15 UTC 2022 - 3.1K bytes - Viewed (0) -
src/cmd/go/internal/vcweb/vcstest/vcstest.go
return srv, nil } func (srv *Server) Close() error { if vcs.VCSTestRepoURL != srv.HTTP.URL { panic("vcs URL hooks modified before Close") } vcs.VCSTestRepoURL = "" vcs.VCSTestHosts = nil web.DisableTestHooks() srv.HTTP.Close() srv.HTTPS.Close() err := srv.vcweb.Close() if rmErr := os.RemoveAll(srv.workDir); err == nil { err = rmErr } return err
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Oct 25 13:44:48 UTC 2022 - 3.8K bytes - Viewed (0)