Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 609 for await (0.11 sec)

  1. docs/en/docs/async.md

    ```Python
    burgers = await get_burgers(2)
    ```
    
    The key here is the `await`. It tells Python that it has to wait ⏸ for `get_burgers(2)` to finish doing its thing 🕙 before storing the results in `burgers`. With that, Python will know that it can go and do something else 🔀 ⏯ in the meanwhile (like receiving another request).
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Aug 28 23:33:37 UTC 2024
    - 23.5K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

        assertTrue(listenerLatch.await(5, SECONDS));
        assertTrue(task.isDone());
        assertFalse(task.isCancelled());
      }
    
      public void testListenerCalledOnException() throws Exception {
        throwException = true;
    
        // Start up the task and unblock the latch to finish the task.
        exec.execute(task);
        runLatch.await();
        taskLatch.countDown();
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  3. docs/en/docs/js/termynal.js

                }
    
                else if (type == 'progress') {
                    await this.progress(line);
                    await this._wait(delay);
                }
    
                else {
                    this.container.appendChild(line);
                    await this._wait(delay);
                }
    
                line.removeAttribute(`${this.pfx}-cursor`);
            }
            this.addRestart()
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu May 12 00:06:16 UTC 2022
    - 9.3K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java

            executor.execute(wrapper);
          }
          barrier.await(); // release the threads!
          barrier.await(); // wait for them all to complete
          assertEquals(1, task.get().intValue());
          assertEquals(1, counter.get());
        }
        executor.shutdown();
      }
    
      @J2ktIncompatible
      @GwtIncompatible // blocking wait
      public void testToString() throws Exception {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 15:41:36 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

        assertTrue(listenerLatch.await(5, SECONDS));
        assertTrue(task.isDone());
        assertFalse(task.isCancelled());
      }
    
      public void testListenerCalledOnException() throws Exception {
        throwException = true;
    
        // Start up the task and unblock the latch to finish the task.
        exec.execute(task);
        runLatch.await();
        taskLatch.countDown();
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  6. tests/test_ws_router.py

        await websocket.accept()
        await websocket.send_text(pathparam)
        await websocket.send_text(queryparam)
        await websocket.close()
    
    
    async def ws_dependency():
        return "Socket Dependency"
    
    
    @router.websocket("/router-ws-depends/")
    async def router_ws_decorator_depends(
        websocket: WebSocket, data=Depends(ws_dependency)
    ):
        await websocket.accept()
        await websocket.send_text(data)
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Jun 11 19:08:14 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  7. docs_src/websockets/tutorial003_py39.py

                await connection.send_text(message)
    
    
    manager = ConnectionManager()
    
    
    @app.get("/")
    async def get():
        return HTMLResponse(html)
    
    
    @app.websocket("/ws/{client_id}")
    async def websocket_endpoint(websocket: WebSocket, client_id: int):
        await manager.connect(websocket)
        try:
            while True:
                data = await websocket.receive_text()
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Mar 18 12:29:59 UTC 2023
    - 2.5K bytes
    - Viewed (0)
  8. tests/test_ws_dependencies.py

    async def index(websocket: WebSocket, deps: DepList):
        await websocket.accept()
        await websocket.send_text(json.dumps(deps))
        await websocket.close()
    
    
    @router.websocket("/router", dependencies=[create_dependency("routerindex")])
    async def routerindex(websocket: WebSocket, deps: DepList):
        await websocket.accept()
        await websocket.send_text(json.dumps(deps))
        await websocket.close()
    
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Jun 11 20:35:39 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  9. tests/test_datastructures.py

        stream = io.BytesIO(b"data")
        file = UploadFile(filename="file", file=stream, size=4)
        assert await file.read() == b"data"
        assert file.size == 4
        await file.write(b" and more data!")
        assert await file.read() == b""
        assert file.size == 19
        await file.seek(0)
        assert await file.read() == b"data and more data!"
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Oct 18 12:36:40 UTC 2023
    - 2K bytes
    - Viewed (0)
  10. docs/tr/docs/async.md

    # Concurrency ve async / await
    
    *path operasyon fonksiyonu* için `async def `sözdizimi,  asenkron kod, eşzamanlılık ve paralellik hakkında bazı ayrıntılar.
    
    ## Aceleniz mi var?
    
    <abbr title="too long; didn't read"><strong>TL;DR:</strong></abbr>
    
    Eğer `await` ile çağrılması gerektiğini belirten üçüncü taraf kütüphaneleri kullanıyorsanız, örneğin:
    
    ```Python
    results = await some_library()
    ```
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 21.9K bytes
    - Viewed (0)
Back to top