Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 219 for LOOP (0.02 seconds)

  1. internal/s3select/jstream/scanner_test.go

    loop:
    	for {
    		_, err := br.ReadByte()
    		switch err {
    		case nil:
    			continue loop
    		case io.EOF:
    			break loop
    		default:
    			panic(err)
    		}
    	}
    }
    
    func BenchmarkScanner(b *testing.B) {
    	b.Run("small", func(b *testing.B) {
    		for b.Loop() {
    			benchmarkScanner(smallInput)
    		}
    	})
    	b.Run("medium", func(b *testing.B) {
    		for b.Loop() {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3.1K bytes
    - Click Count (0)
  2. docs/en/docs/advanced/stream-data.md

    /// info
    
    The example above is actually an exception, because the `io.BytesIO` object is already in memory, so reading it won't block anything.
    
    But in many cases reading a file or a file-like object would block.
    
    ///
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 5.4K bytes
    - Click Count (0)
  3. docs/en/docs/advanced/async-tests.md

    /// tip
    
    If you encounter a `RuntimeError: Task attached to a different loop` when integrating asynchronous function calls in your tests (e.g. when using [MongoDB's MotorClient](https://stackoverflow.com/questions/41584243/runtimeerror-task-attached-to-a-different-loop)), remember to instantiate objects that need an event loop only within async functions, e.g. an `@app.on_event("startup")` callback.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 3.8K bytes
    - Click Count (0)
  4. src/bufio/scan.go

    		// be extra careful: Scanner is for safe, simple jobs.
    		for loop := 0; ; {
    			n, err := s.r.Read(s.buf[s.end:len(s.buf)])
    			if n < 0 || len(s.buf)-s.end < n {
    				s.setErr(ErrBadReadCount)
    				break
    			}
    			s.end += n
    			if err != nil {
    				s.setErr(err)
    				break
    			}
    			if n > 0 {
    				s.empties = 0
    				break
    			}
    			loop++
    			if loop > maxConsecutiveEmptyReads {
    				s.setErr(io.ErrNoProgress)
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Wed May 21 18:05:26 GMT 2025
    - 14.2K bytes
    - Click Count (0)
  5. docs/ru/llm-prompt.md

    * mount (noun): точка монтирования / mount (keep in English if it's a FastAPI keyword)
    * plugin: плагин
    * plug-in: плагин
    * full stack: full stack (do not translate)
    * full-stack: full-stack (do not translate)
    * loop (as in async loop): цикл событий
    * Machine Learning: Машинное обучение
    * Deep Learning: Глубокое обучение
    * callback hell: callback hell (clarify as `ад обратных вызовов`)
    * on the fly: на лету
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Jan 22 07:07:05 GMT 2026
    - 6.5K bytes
    - Click Count (0)
  6. docs/zh-hant/docs/advanced/async-tests.md

    由於測試函式現在是非同步的,你也可以在測試中呼叫(並 `await`)其他 `async` 函式,和在程式碼其他地方一樣。
    
    /// tip
    
    如果在將非同步呼叫整合進測試時遇到 `RuntimeError: Task attached to a different loop`(例如使用 [MongoDB 的 MotorClient](https://stackoverflow.com/questions/41584243/runtimeerror-task-attached-to-a-different-loop) 時),請記得:需要事件迴圈的物件只應在非同步函式內實例化,例如在 `@app.on_event("startup")` 回呼中。
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Mar 20 17:05:38 GMT 2026
    - 3.5K bytes
    - Click Count (0)
  7. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt

          assertThat(e).isInstanceOf(ConnectionEvent.ConnectStart::class.java)
        } else {
          eventSequence.forEach loop@{
            when (e.closes(it)) {
              null -> return
    
              // no open event
              true -> return
    
              // found open event
              false -> return@loop // this is not the open event so continue
            }
          }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 5.8K bytes
    - Click Count (0)
  8. internal/disk/stat_linux.go

    	if firstTime {
    		bfs, err := blockdevice.NewDefaultFS()
    		if err == nil {
    			devName := ""
    			diskstats, _ := bfs.ProcDiskstats()
    			for _, dstat := range diskstats {
    				// ignore all loop devices
    				if strings.HasPrefix(dstat.DeviceName, "loop") {
    					continue
    				}
    				if dstat.MajorNumber == info.Major && dstat.MinorNumber == info.Minor {
    					devName = dstat.DeviceName
    					break
    				}
    			}
    			if devName != "" {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 4.8K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/base/Throwables.java

       * </pre>
       *
       * @throws IllegalArgumentException if there is a loop in the causal chain
       */
      public static Throwable getRootCause(Throwable throwable) {
        // Keep a second pointer that slowly walks the causal chain. If the fast pointer ever catches
        // the slower pointer, then there's a loop.
        Throwable slowPointer = throwable;
        boolean advanceSlowPointer = false;
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 20.6K bytes
    - Click Count (0)
  10. guava/src/com/google/common/base/Throwables.java

       * </pre>
       *
       * @throws IllegalArgumentException if there is a loop in the causal chain
       */
      public static Throwable getRootCause(Throwable throwable) {
        // Keep a second pointer that slowly walks the causal chain. If the fast pointer ever catches
        // the slower pointer, then there's a loop.
        Throwable slowPointer = throwable;
        boolean advanceSlowPointer = false;
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 20.6K bytes
    - Click Count (0)
Back to Top