Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 628 for kuwait (0.1 sec)

  1. docs/pt/docs/advanced/websockets.md

    ///
    
    ## Aguardar por mensagens e enviar mensagens
    
    Em sua rota WebSocket você pode esperar (`await`) por mensagens e enviar mensagens.
    
    {*../../docs_src/websockets/tutorial001.py hl[48:52]*}
    
    Você pode receber e enviar dados binários, de texto e JSON.
    
    ## Tente você mesmo
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Oct 31 12:20:59 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

          queue.enqueue(incrementingEvent(counters, listener, 4));
          queue.enqueue(countDownEvent(latch));
          assertEquals(0, counters.size());
          queue.dispatch();
          latch.await();
          assertEquals(multiset(listener, 4), counters);
        } finally {
          service.shutdown();
        }
      }
    
      public void testEnqueueAndDispatch_multithreaded_withThrowingRunnable()
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Feb 09 22:57:07 UTC 2022
    - 8.2K bytes
    - Viewed (0)
  3. cmd/erasure.go

    				w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout())
    				return w.Run(func() error {
    					wait := deleteCleanupSleeper.Timer(ctx)
    					removeAll(pathJoin(drivePath, minioMetaTmpDeletedBucket, ddir))
    					wait()
    					return nil
    				})
    			})
    		}(disk)
    	}
    	wg.Wait()
    }
    
    // nsScanner will start scanning buckets and send updated totals as they are traversed.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  4. docs/em/docs/tutorial/request-files.md

    * `read(size)`: ✍ `size` (`int`) 🔢/🦹 📁.
    * `seek(offset)`: 🚶 🔢 🧘 `offset` (`int`) 📁.
        * 🤶 Ⓜ., `await myfile.seek(0)` 🔜 🚶 ▶️ 📁.
        * 👉 ✴️ ⚠ 🚥 👆 🏃 `await myfile.read()` 🕐 & ⤴️ 💪 ✍ 🎚 🔄.
    * `close()`: 🔐 📁.
    
    🌐 👫 👩‍🔬 `async` 👩‍🔬, 👆 💪 "⌛" 👫.
    
    🖼, 🔘 `async` *➡ 🛠️ 🔢* 👆 💪 🤚 🎚 ⏮️:
    
    ```Python
    contents = await myfile.read()
    ```
    
    🚥 👆 🔘 😐 `def` *➡ 🛠️ 🔢*, 👆 💪 🔐 `UploadFile.file` 🔗, 🖼:
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  5. android/guava-testlib/test/com/google/common/testing/FakeTickerTest.java

                      startLatch.countDown();
                      startLatch.await();
                      callable.call();
                      doneLatch.countDown();
                      return null;
                    }
                  });
        }
        doneLatch.await();
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 22 13:49:09 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  6. 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 Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 9K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/MoreExecutors.java

       * is complete. It does so by using daemon threads and adding a shutdown hook to wait for their
       * completion.
       *
       * <p>This is mainly for fixed thread pools. See {@link Executors#newFixedThreadPool(int)}.
       *
       * @param executor the executor to modify to make sure it exits when the application is finished
       * @param terminationTimeout how long to wait for the executor to finish before terminating the
       *     JVM
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 44.1K bytes
    - Viewed (0)
  8. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 15.3K bytes
    - Viewed (0)
  9. prepare_stmt.go

    		db.Mux.RUnlock()
    		// wait for other goroutines prepared
    		<-stmt.prepared
    		if stmt.prepareErr != nil {
    			return Stmt{}, stmt.prepareErr
    		}
    
    		return *stmt, nil
    	}
    	db.Mux.RUnlock()
    
    	db.Mux.Lock()
    	// double check
    	if stmt, ok := db.Stmts[query]; ok && (!stmt.Transaction || isTransaction) {
    		db.Mux.Unlock()
    		// wait for other goroutines prepared
    		<-stmt.prepared
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Aug 22 11:02:05 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  10. tests/test_dependency_contextvars.py

        legacy_request_state_context_var.reset(contextvar_token)
    
    
    @app.middleware("http")
    async def custom_middleware(
        request: Request, call_next: Callable[[Request], Awaitable[Response]]
    ):
        response = await call_next(request)
        response.headers["custom"] = "foo"
        return response
    
    
    @app.get("/user", dependencies=[Depends(set_up_request_state_dependency)])
    def get_user():
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Feb 17 12:40:12 UTC 2022
    - 1.5K bytes
    - Viewed (0)
Back to top