Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 173 for _loop (0.09 sec)

  1. doc/next/6-stdlib/99-minor/testing/61515.md

    Benchmarks can use the new [B.Loop] method in `for b.Loop() { ... }` loops to determine if iteration should continue....
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Sep 20 19:09:41 UTC 2024
    - 118 bytes
    - Viewed (0)
  2. docs/pt/docs/advanced/async-tests.md

    Se você se deparar com um `RuntimeError: Task attached to a different loop` ao integrar funções assíncronas em seus testes (e.g. ao utilizar o <a href="https://stackoverflow.com/questions/41584243/runtimeerror-task-attached-to-a-different-loop" class="external-link" target="_blank">MotorClient do MongoDB</a>) Lembre-se de instanciar objetos que precisam de um loop de eventos (*event loop*) apenas em funções assíncronas, e.g. um *"callback"* `'@app.on_event("startup")`.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  3. 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)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Oct 23 09:06:30 UTC 2023
    - 14.2K bytes
    - Viewed (0)
  4. internal/s3select/jstream/scanner_test.go

    			benchmarkBufioReader(largeInput)
    		}
    	})
    }
    
    func benchmarkBufioReader(b []byte) {
    	br := bufio.NewReader(bytes.NewReader(b))
    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) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  5. 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
            }
          }
          Assertions.fail<Any>("event $e without matching start event")
        }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  6. 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 != "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 26 19:34:50 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/-CacheControlCommon.kt

      var maxStaleSeconds = -1
      var minFreshSeconds = -1
      var onlyIfCached = false
      var noTransform = false
      var immutable = false
    
      var canUseHeaderValue = true
      var headerValue: String? = null
    
      loop@ for (i in 0 until headers.size) {
        val name = headers.name(i)
        val value = headers.value(i)
    
        when {
          name.equals("Cache-Control", ignoreCase = true) -> {
            if (headerValue != null) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 15 13:41:01 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  8. docs/de/docs/advanced/async-tests.md

    | "Tipp"
    
    Wenn Sie einen `RuntimeError: Task attached to a different loop` erhalten, wenn Sie asynchrone Funktionsaufrufe in Ihre Tests integrieren (z. B. bei Verwendung von <a href="https://stackoverflow.com/questions/41584243/runtimeerror-task-attached-to-a-different-loop" class="external-link" target="_blank">MongoDBs MotorClient</a>), dann denken Sie daran, Objekte zu instanziieren, die einen Event Loop nur innerhalb asynchroner Funktionen benötigen, z. B. einen `@app.on_event("startup")`-Callback....
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 27 15:34:47 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  9. 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 <a href="https://stackoverflow.com/questions/41584243/runtimeerror-task-attached-to-a-different-loop" class="external-link" target="_blank">MongoDB's MotorClient</a>), remember to instantiate objects that need an event loop only within async functions, e.g. an `'@app.on_event("startup")` callback.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 27 15:43:29 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  10. cmd/xl-storage-errors.go

    func isSysErrTooLong(err error) bool {
    	return errors.Is(err, syscall.ENAMETOOLONG)
    }
    
    // Check if the given error corresponds to the ELOOP (too many symlinks).
    func isSysErrTooManySymlinks(err error) bool {
    	return errors.Is(err, syscall.ELOOP)
    }
    
    // Check if the given error corresponds to ENOTEMPTY for unix,
    // EEXIST for solaris variants,
    // and ERROR_DIR_NOT_EMPTY for windows (directory not empty).
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Mar 06 16:56:29 UTC 2023
    - 3.8K bytes
    - Viewed (0)
Back to top