- Sort Score
- Num 10 results
- Language All
Results 701 - 710 of 744 for badsync (0.04 seconds)
-
docs/en/docs/tutorial/dependencies/dependencies-with-yield.md
The code following the `yield` statement is executed after the response: {* ../../docs_src/dependencies/tutorial007_py39.py hl[5:6] *} /// tip You can use `async` or regular functions. **FastAPI** will do the right thing with each, the same as with normal dependencies. /// ## A dependency with `yield` and `try` { #a-dependency-with-yield-and-try }Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 20:41:43 GMT 2025 - 12.9K bytes - Click Count (0) -
internal/s3select/csv/reader.go
csvDstPool bpool.Pool[[][]string] // pool of [][]string used for output close chan struct{} // used for shutting down the splitter before end of stream readerWg sync.WaitGroup // used to keep track of async reader. } // queueItem is an item in the queue. type queueItem struct { input []byte // raw input sent to the worker dst chan [][]string // result of block decode
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 8.8K bytes - Click Count (0) -
internal/dsync/lock-args_gen.go
// Code generated by github.com/tinylib/msgp DO NOT EDIT. package dsync import ( "github.com/tinylib/msgp/msgp" ) // DecodeMsg implements msgp.Decodable func (z *LockArgs) DecodeMsg(dc *msgp.Reader) (err error) { var field []byte _ = field var zb0001 uint32 zb0001, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err) return } for zb0001 > 0 { zb0001-- field, err = dc.ReadMapKeyPtr()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 10.2K bytes - Click Count (0) -
docs/metrics/prometheus/list.md
| `minio_notify_current_send_in_progress` | Number of concurrent async Send calls active to all targets (deprecated, please use `minio_notify_target_current_send_in_progress` instead) |
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 43.4K bytes - Click Count (0) -
internal/s3select/json/preader.go
close chan struct{} // used for shutting down the splitter before end of stream readerWg sync.WaitGroup // used to keep track of async reader. } // queueItem is an item in the queue. type queueItem struct { input []byte // raw input sent to the worker dst chan []jstream.KVS // result of block decodeCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 6.5K bytes - Click Count (0) -
docs/zh/docs/advanced/custom-response.md
如果您有类似文件的对象(例如,由 `open()` 返回的对象),则可以在 `StreamingResponse` 中将其返回。 包括许多与云存储,视频处理等交互的库。 {* ../../docs_src/custom_response/tutorial008.py hl[2,10:12,14] *} /// tip | 小贴士 注意在这里,因为我们使用的是不支持 `async` 和 `await` 的标准 `open()`,我们使用普通的 `def` 声明了路径操作。 /// ### `FileResponse` 异步传输文件作为响应。 与其他响应类型相比,接受不同的参数集进行实例化: * `path` - 要流式传输的文件的文件路径。 * `headers` - 任何自定义响应头,传入字典类型。Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Mon Nov 18 02:25:44 GMT 2024 - 7.5K bytes - Click Count (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/transfer/SimplexTransferListener.java
public void process(Consumer<TransferEvent> consumer) { consumer.accept(event); } public void waitForProcessed() throws InterruptedException { // nothing, is async } } private static class BlockingExchange extends Exchange { private final CountDownLatch latch = new CountDownLatch(1); private BlockingExchange(TransferEvent event) {Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Thu Feb 06 11:28:05 GMT 2025 - 8.7K bytes - Click Count (0) -
cmd/untar.go
name = trimLeadingSlash(path.Clean(name)) default: // ignore symlink'ed continue } if o.prefixAll != "" { name = pathJoin(o.prefixAll, name) } // Do small files async n++ if header.Size <= xioutil.MediumBlock { asyncWriters <- struct{}{} bufp := xioutil.ODirectPoolMedium.Get() b := (*bufp)[:header.Size] if _, err := io.ReadFull(tarReader, b); err != nil {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 6K bytes - Click Count (2) -
docs/ja/docs/tutorial/dependencies/sub-dependencies.md
高度なシナリオでは、「キャッシュされた」値を使うのではなく、同じリクエストの各ステップ(おそらく複数回)で依存関係を呼び出す必要があることがわかっている場合、`Depens`を使用する際に、`use_cache=False`というパラメータを設定することができます。 ```Python hl_lines="1" async def needy_dependency(fresh_value: str = Depends(get_value, use_cache=False)): return {"fresh_value": fresh_value} ``` ## まとめ ここで使われている派手な言葉は別にして、**依存性注入** システムは非常にシンプルです。 *path operation関数*と同じように見えるただの関数です。
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Mon Nov 18 02:25:44 GMT 2024 - 4.3K bytes - Click Count (0) -
fastapi/applications.py
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 21:25:59 GMT 2025 - 176.3K bytes - Click Count (0)