- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 2,355 for nwait (0.05 sec)
-
src/time/sleep_test.go
} } if err != nil { t.Fatal(err) } } var slots = []int{5, 3, 6, 6, 6, 1, 1, 2, 7, 9, 4, 8, 0} type afterResult struct { slot int t Time } func await(slot int, result chan<- afterResult, ac <-chan Time) { result <- afterResult{slot, <-ac} } func testAfterQueuing1(delta Duration, after func(Duration) <-chan Time) error {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 22 16:33:57 UTC 2024 - 22.5K bytes - Viewed (0) -
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: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sun Jun 11 19:08:14 UTC 2023 - 7.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/ProcessHelper.java
} }, "ProcessCloser-output-" + sessionId).start(); try { latch.await(10, TimeUnit.SECONDS); } catch (final InterruptedException e) { logger.warn("Interrupted to wait a process.", e); } try { process.destroyForcibly().waitFor(processDestroyTimeout, TimeUnit.SECONDS);
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 6.4K bytes - Viewed (0) -
src/log/log_test.go
// Ensure that a newline is added only if the buffer lacks a newline suffix. b.Reset() l.SetFlags(0) l.SetPrefix("\n") l.Output(0, "") if got := b.String(); got != "\n" { t.Errorf("message mismatch:\ngot %q\nwant %q", got, "\n") } } func TestUTCFlag(t *testing.T) { var b strings.Builder l := New(&b, "Test:", LstdFlags) l.SetFlags(Ldate | Ltime | LUTC)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 21 20:04:37 UTC 2023 - 7.4K bytes - Viewed (0) -
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: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sun Jun 11 20:35:39 UTC 2023 - 2.1K bytes - Viewed (1) -
cmd/admin-heal-ops.go
h.countScanned(healType) if source.noWait { select { case globalBackgroundHealRoutine.tasks <- task: if serverDebugLog { fmt.Printf("Task in the queue: %#v\n", task) } default: // task queue is full, no more workers, we shall move on and heal later. return nil } // Don't wait for result return nil } // respCh must be set to wait for result.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 09 18:04:41 UTC 2024 - 25.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java
service.startAsync().awaitRunning(); for (int i = 1; i < 10; i++) { service.runFirstBarrier.await(); assertEquals(i, service.numberOfTimesRunCalled.get()); service.runSecondBarrier.await(); } service.runFirstBarrier.await(); service.stopAsync(); service.runSecondBarrier.await(); service.stopAsync().awaitTerminated(); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 22.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java
service.startAsync().awaitRunning(); for (int i = 1; i < 10; i++) { service.runFirstBarrier.await(); assertEquals(i, service.numberOfTimesRunCalled.get()); service.runSecondBarrier.await(); } service.runFirstBarrier.await(); service.stopAsync(); service.runSecondBarrier.await(); service.stopAsync().awaitTerminated(); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 22.5K bytes - Viewed (0) -
docs/en/docs/advanced/events.md
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Apr 18 19:53:19 UTC 2024 - 7.8K bytes - Viewed (0) -
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: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat Mar 18 12:29:59 UTC 2023 - 2.5K bytes - Viewed (0)