- Sort Score
- Num 10 results
- Language All
Results 161 - 170 of 516 for _wait (0.02 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
fastapi/routing.py
router = APIRouter() @router.websocket("/ws") async def websocket_endpoint(websocket: WebSocket): await websocket.accept() while True: data = await websocket.receive_text() await websocket.send_text(f"Message text was: {data}") app.include_router(router) ``` """
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sat Dec 27 12:54:56 GMT 2025 - 174.6K bytes - Click Count (0) -
docs/es/docs/advanced/events.md
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 20:41:43 GMT 2025 - 8.5K bytes - Click Count (0) -
internal/dsync/dsync_test.go
cancel := func() { cl() wg.Done() } if !dm.GetLock(ctx, cancel, id, source, Options{Timeout: 5 * time.Minute}) { t.Fatal("GetLock() should be successful") } // Wait until context is canceled wg.Wait() if ctx.Err() == nil { t.Fatal("Unexpected error", ctx.Err()) } // Should be safe operation in all cases dm.Unlock(t.Context()) } // Test Unlock should not timeout
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 10.8K bytes - Click Count (0) -
src/main/java/jcifs/smb1/smb1/TransactNamedPipeInputStream.java
} @Override public int read() throws IOException { int result = -1; synchronized (lock) { try { while (used == 0) { lock.wait(); } } catch (final InterruptedException ie) { throw new IOException(ie.getMessage()); } result = pipe_buf[beg_idx] & 0xFF;Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 14 07:14:38 GMT 2025 - 4.6K bytes - Click Count (0) -
docs/releasing.md
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Nov 19 15:45:22 GMT 2025 - 1.1K bytes - Click Count (0) -
cmd/untar.go
return err } } header, err := tarReader.Next() switch { // if no more files are found return case err == io.EOF: wg.Wait() return asyncErr // return any other error case err != nil: wg.Wait() extra := "" if n > 0 { extra = fmt.Sprintf(" after %d successful object(s)", n) } return fmt.Errorf("tar file error: %w%s", err, extra)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 6K bytes - Click Count (2) -
mockwebserver/src/test/java/mockwebserver3/CustomDispatcherTest.kt
val dispatcher: Dispatcher = object : Dispatcher() { override fun dispatch(request: RecordedRequest): MockResponse { if (request.url.encodedPath == firstRequest) { latch.await() } return MockResponse() } } mockWebServer.dispatcher = dispatcher val startsFirst = buildRequestThread(firstRequest, firstResponseCode) startsFirst.start()Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Jun 18 12:28:21 GMT 2025 - 3.2K bytes - Click Count (1) -
docs/pt/docs/advanced/events.md
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 20:41:43 GMT 2025 - 8.8K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
* than the given time. The manager will become healthy after all the component services have * reached the {@linkplain State#RUNNING running} state. * * @param timeout the maximum time to wait * @throws TimeoutException if not all of the services have finished starting within the deadline * @throws IllegalStateException if the service manager reaches a state from which it cannotCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 22 17:49:12 GMT 2025 - 33.2K bytes - Click Count (1) -
guava/src/com/google/common/util/concurrent/ServiceManager.java
* than the given time. The manager will become healthy after all the component services have * reached the {@linkplain State#RUNNING running} state. * * @param timeout the maximum time to wait * @throws TimeoutException if not all of the services have finished starting within the deadline * @throws IllegalStateException if the service manager reaches a state from which it cannotCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 22 17:49:12 GMT 2025 - 32.9K bytes - Click Count (0)