Search Options

Results per page
Sort
Preferred Languages
Advance

Results 371 - 380 of 603 for _wait (0.02 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top