- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 3,379 for FClose (0.14 sec)
-
docs_src/dependencies/tutorial009.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) -
android/guava/src/com/google/common/io/CountingOutputStream.java
out.write(b); count++; } // Overriding close() because FilterOutputStream's close() method pre-JDK8 has bad behavior: // it silently ignores any exception thrown by flush(). Instead, just close the delegate stream. // It should flush itself if necessary. @Override public void close() throws IOException { out.close(); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 28 20:13:02 UTC 2023 - 2K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/stress-start-stop.go
wg.Add(1) go func() { <-done wg.Done() }() rp, wp, err := os.Pipe() if err != nil { log.Fatalf("failed to create pipe: %v", err) return } defer func() { rp.Close() wp.Close() }() wg.Add(1) go func() { var tmp [1]byte rp.Read(tmp[:]) <-done wg.Done() }() time.Sleep(time.Millisecond) go func() { runtime.LockOSThread() for {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 2.7K bytes - Viewed (0) -
docs_src/dependencies/tutorial008_an.py
async def dependency_a(): dep_a = generate_dep_a() try: yield dep_a finally: dep_a.close() async def dependency_b(dep_a: Annotated[DepA, Depends(dependency_a)]): dep_b = generate_dep_b() try: yield dep_b finally: dep_b.close(dep_a) async def dependency_c(dep_b: Annotated[DepB, Depends(dependency_b)]): dep_c = generate_dep_c() try:
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat Mar 18 12:29:59 UTC 2023 - 531 bytes - Viewed (0) -
pkg/kubelet/server/server_test.go
t.Fatalf("Got error GETing: %v", err) } defer resp.Body.Close() if resp.StatusCode != expectedErrorCode { t.Errorf("expected status code %d, got %d", expectedErrorCode, resp.StatusCode) } } // Ensure all registered handlers & services have an associated testcase. func TestAuthzCoverage(t *testing.T) { fw := newServerTest() defer fw.testHTTPServer.Close() // method:path -> has coverage
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.5K bytes - Viewed (0) -
tests/fuzz/pki_fuzzer.go
if err != nil { return 0 } defer certFile.Close() defer os.Remove("certfile") certFileBytes, err := f.GetBytes() if err != nil { return 0 } _, err = certFile.Write(certFileBytes) if err != nil { return 0 } privKeyFile, err := os.Create("privKeyFile") if err != nil { return 0 } defer privKeyFile.Close() defer os.Remove("privKeyFile")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 05 14:00:25 UTC 2023 - 5.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/wsstream/conn.go
for _, s := range conn.channels { s.Close() } var err error if conn.ws != nil { err = conn.ws.Close() } return err } // Close is only valid after Open has been called func (conn *Conn) Close() error { <-conn.ready return conn.closeNonThreadSafe() } // protocolSupportsStreamClose returns true if the passed protocol // supports the stream close signal (currently only V5 remotecommand);
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 14.5K bytes - Viewed (0) -
.github/workflows/invalid_question.yml
name: "Close invalid questions issues" on: schedule: - cron: "*/10 * * * *" 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:
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Tue Apr 11 02:27:05 UTC 2023 - 1.2K bytes - Viewed (0) -
src/cmd/compile/internal/syntax/testdata/chans.go
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: Wed Mar 30 18:02:18 UTC 2022 - 1.8K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/inputs/undeclared/UndeclaredFileAccess.groovy
String getKotlinExpression() { "FileInputStream(File(\"$filePath\")).close()" } @Override String getJavaExpression() { """ ((Supplier<Object>) () -> { try { new FileInputStream(new File("$filePath")).close(); } catch (IOException e) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 9.6K bytes - Viewed (0)