Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 517 for bgwait (0.11 sec)

  1. docs/pt/docs/advanced/async-tests.md

    {* ../../docs_src/async_tests/test_main.py hl[9:12] *}
    
    Isso é equivalente a:
    
    ```Python
    response = client.get('/')
    ```
    
    ...que nós utilizamos para fazer as nossas requisições utilizando o `TestClient`.
    
    /// tip | Dica
    
    Note que nós estamos utilizando async/await com o novo `AsyncClient` - a requisição é assíncrona.
    
    ///
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Nov 18 02:25:44 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/WholeOperationTimeoutTest.kt

            override fun onResponse(
              call: Call,
              response: Response,
            ) {
              response.close()
              latch.countDown()
            }
          },
        )
        latch.await()
        assertThat(call.isCanceled()).isTrue()
        assertThat(exceptionRef.get()).isNotNull()
      }
    
      @Test
      fun timeoutProcessing() {
        server.enqueue(
          MockResponse
            .Builder()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 10.6K bytes
    - Viewed (0)
  3. cmd/peer-s3-server.go

    					return serr
    				}
    
    				beforeState[index] = madmin.DriveStateMissing
    				afterState[index] = madmin.DriveStateMissing
    
    				return serr
    			}
    			return nil
    		}, index)
    	}
    
    	errs := g.Wait()
    
    	// Initialize heal result info
    	res = madmin.HealResultItem{
    		Type:      madmin.HealItemBucket,
    		Bucket:    bucket,
    		DiskCount: len(localDrives),
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/TimeLimiter.java

       * @param timeoutDuration with timeoutUnit, the maximum length of time that callers are willing to
       *     wait on each method call to the proxy
       * @param timeoutUnit with timeoutDuration, the maximum length of time that callers are willing to
       *     wait on each method call to the proxy
       * @return a time-limiting proxy
       * @throws IllegalArgumentException if {@code interfaceType} is a regular class, enum, or
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Jan 18 02:54:30 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb1/util/transport/Transport.java

                te = null;
                thread = new Thread(this, name);
                thread.setDaemon(true);
    
                synchronized (thread) {
                    thread.start();
                    thread.wait(timeout); /* wait for doConnect */
    
                    switch (state) {
                    case 1: /* doConnect never returned */
                        state = 0;
                        thread = null;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 11.3K bytes
    - Viewed (0)
  6. src/main/java/jcifs/util/transport/Transport.java

                            continue;
                        }
    
                        curResp.wait();
                        if (handleIntermediate(request, curResp)) {
                            continue;
                        }
                        if (log.isDebugEnabled()) {
                            log.debug("Wait returned state is " + this.state);
                        }
                        if (isDisconnected()) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 27.8K bytes
    - Viewed (0)
  7. docs/ru/docs/advanced/async-tests.md

    {* ../../docs_src/async_tests/test_main.py hl[9:12] *}
    
    Это эквивалентно следующему:
    
    ```Python
    response = client.get('/')
    ```
    
    ...которое мы использовали для отправки наших запросов с `TestClient`.
    
    /// tip | Подсказка
    
    Обратите внимание, что мы используем async/await с `AsyncClient` - запрос асинхронный.
    
    ///
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Jan 27 15:36:13 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  8. docs/em/docs/advanced/websockets.md

    /// note | 📡 ℹ
    
    👆 💪 ⚙️ `from starlette.websockets import WebSocket`.
    
    **FastAPI** 🚚 🎏 `WebSocket` 🔗 🏪 👆, 👩‍💻. ✋️ ⚫️ 👟 🔗 ⚪️➡️ 💃.
    
    ///
    
    ## ⌛ 📧 & 📨 📧
    
    👆 *️⃣ 🛣 👆 💪 `await` 📧 & 📨 📧.
    
    {* ../../docs_src/websockets/tutorial001.py hl[48:52] *}
    
    👆 💪 📨 & 📨 💱, ✍, & 🎻 💽.
    
    ## 🔄 ⚫️
    
    🚥 👆 📁 📛 `main.py`, 🏃 👆 🈸 ⏮️:
    
    <div class="termy">
    
    ```console
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Nov 18 02:25:44 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  9. src/test/java/org/codelibs/fess/helper/AbstractConfigHelperTest.java

            configHelper.setLoadCallback(() -> {
                latch.countDown();
                return 1;
            });
    
            configHelper.update();
    
            assertTrue("Load method should be called within 5 seconds", latch.await(5, TimeUnit.SECONDS));
            assertEquals(1, configHelper.getLoadCallCount());
        }
    
        public void test_update_multipleCallsIncrementLoadCount() throws InterruptedException {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jul 12 00:03:47 UTC 2025
    - 4.7K bytes
    - Viewed (0)
  10. src/test/java/org/codelibs/fess/helper/ProcessHelperTest.java

                assertTrue(processHelper.isProcessRunning());
    
                // Wait a bit for the processes to start
                Thread.sleep(50);
    
                // Destroy all processes
                processHelper.destroy();
    
                // Wait a bit for destruction to complete
                Thread.sleep(100);
    
                assertFalse(processHelper.isProcessRunning());
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jul 12 05:35:01 UTC 2025
    - 15.1K bytes
    - Viewed (0)
Back to top