- Sort Score
- Result 10 results
- Languages All
Results 371 - 380 of 603 for _wait (0.03 sec)
-
docs/fr/docs/index.md
return {"item_id": item_id, "q": q} ``` <details markdown="1"> <summary>Ou utilisez <code>async def</code> ...</summary> Si votre code utilise `async` / `await`, utilisez `async def` : ```Python hl_lines="9 14" from typing import Union from fastapi import FastAPI app = FastAPI() @app.get("/") async def read_root():
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 20 19:20:23 UTC 2024 - 22K bytes - Viewed (0) -
docs/zh-hant/docs/index.md
def read_item(item_id: int, q: Union[str, None] = None): return {"item_id": item_id, "q": q} ``` <details markdown="1"> <summary>或可以使用 <code>async def</code>...</summary> 如果你的程式使用 `async` / `await`,請使用 `async def`: ```Python hl_lines="9 14" from typing import Union from fastapi import FastAPI app = FastAPI() @app.get("/") async def read_root(): return {"Hello": "World"}
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 20 19:20:23 UTC 2024 - 18.8K bytes - Viewed (0) -
internal/s3select/csv/reader.go
dstRec.nameIndexMap = r.nameIndexMap return dstRec, nil } // Close - closes underlying reader. func (r *Reader) 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 Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 8.9K bytes - Viewed (0) -
internal/grid/README.md
// Return the response for reuse grid.PutByteBuffer(result) return nil }) ``` Context cancellation and timeouts are propagated to the handler. The client does not wait for the remote handler to finish before returning. Returning any error will also cancel the stream remotely.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 9.4K bytes - Viewed (0) -
docs/tr/docs/index.md
def read_item(item_id: int, q: Union[str, None] = None): return {"item_id": item_id, "q": q} ``` <details markdown="1"> <summary>Ya da <code>async def</code>...</summary> Eğer kodunuzda `async` / `await` varsa, `async def` kullanalım: ```Python hl_lines="9 14" from typing import Union from fastapi import FastAPI app = FastAPI() @app.get("/") async def read_root():
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Fri Aug 16 16:50:01 UTC 2024 - 21.9K bytes - Viewed (0) -
cmd/site-replication-utils.go
sm.peerResyncMap[dID] = rs wg.Add(1) go func() { defer wg.Done() saveSiteResyncMetadata(ctx, st, newObjectLayerFn()) }() } } wg.Wait() sm.Unlock() } sTimer.Reset(siteResyncSaveInterval) case <-ctx.Done(): return } } } // update overall site resync state
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 8.9K bytes - Viewed (0) -
docs/debugging/s3-verify/main.go
targetFailed = true } else if tgtSize != tgtCtnt.Size { fmt.Printf("unreadable on target - size differs upon read: %s\n", tgtCtnt.Key) targetFailed = true } }() wg.Wait() sobj.Close() tobj.Close() if !sourceFailed && !targetFailed { ssum := srcSha256.Sum(nil) tsum := tgtSha256.Sum(nil) allgood = bytes.Equal(ssum, tsum) if !allgood {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jun 22 15:12:47 UTC 2022 - 8.4K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver_test.go
assert.Equal(t, len(fds), 1) // in theory we should close the fd, but it's just a test.. assert.Equal(t, m.Payload.(*zdsapi.WorkloadRequest_Add).Add.Uid, uid) // send ack so the server doesn't wait for us. sendAck(ztunClient) // second message should be the snap sent message m, fds = readRequest(t, ztunClient) assert.Equal(t, len(fds), 0)
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Apr 12 21:47:31 UTC 2024 - 8.6K bytes - Viewed (0) -
cmd/bootstrap-peer-server.go
} else { offlineEndpoints = append(offlineEndpoints, fmt.Errorf("%s is unreachable: %w", clnt, err)) } } else { onlineServers++ } mu.Unlock() }(clnt) } wg.Wait() select { case <-ctx.Done(): return ctx.Err() default: // Sleep and stagger to avoid blocked CPU and thundering // herd upon start up sequence.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 01 22:13:18 UTC 2024 - 8.4K bytes - Viewed (0) -
apache-maven/src/assembly/maven/bin/mvn.cmd
@REM MAVEN_ARGS (Optional) Arguments passed to Maven before CLI arguments. @REM MAVEN_BATCH_ECHO (Optional) Set to 'on' to enable the echoing of the batch commands. @REM MAVEN_BATCH_PAUSE (Optional) set to 'on' to wait for a key stroke before ending. @REM MAVEN_OPTS (Optional) Java runtime options used when Maven is executed. @REM MAVEN_SKIP_RC (Optional) Flag to disable loading of mavenrc files.
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Thu Oct 24 12:01:35 UTC 2024 - 7.8K bytes - Viewed (0)