- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 80 for Await (0.11 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
functionBlocking.await(); return immediateFuture(null); } }); ExecutorService executor = Executors.newSingleThreadExecutor(); try { ListenableFuture<?> output = Futures.transformAsync(immediateFuture(null), function, executor); functionCalled.await(); assertThat(output.toString()).contains(function.toString());
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 144.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
functionBlocking.await(); return immediateFuture(null); } }); ExecutorService executor = Executors.newSingleThreadExecutor(); try { ListenableFuture<?> output = Futures.transformAsync(immediateFuture(null), function, executor); functionCalled.await(); assertThat(output.toString()).contains(function.toString());
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 144.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallTest.kt
callback.await(server.url("/a")).assertBody("abc") client.newCall(Request.Builder().url(server.url("/b")).build()).enqueue(callback) callback.await(server.url("/b")).assertBody("def") client.newCall(Request.Builder().url(server.url("/c")).build()).enqueue(callback) callback.await(server.url("/c")).assertBody("ghi")
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 10 19:46:48 UTC 2024 - 142.5K bytes - Viewed (0) -
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) ``` """
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Tue Apr 02 02:48:51 UTC 2024 - 170.1K bytes - Viewed (0) -
fastapi/applications.py
app = FastAPI() @app.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}") ``` """ def decorator(func: DecoratedCallable) -> DecoratedCallable:
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat May 18 00:48:03 UTC 2024 - 172.2K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
if err != nil { t.Fatalf("Creating job: %v", err) } // Await for the Job to appear in the jobLister to ensure so that Job Pod gets tracked correctly. if err := wait.PollUntilContextTimeout(ctx, 10*time.Millisecond, wait.ForeverTestTimeout, false, func(ctx context.Context) (bool, error) { job, _ := manager.jobLister.Jobs(job.GetNamespace()).Get(job.Name)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0) -
src/cmd/internal/obj/x86/asm6.go
{AUNPCKLPD, yxm, Pe, opBytes{0x14}}, {AUNPCKLPS, yxm, Pm, opBytes{0x14}}, {AUMONITOR, ywrfsbase, Pf3, opBytes{0xae, 06}}, {AVERR, ydivl, Pm, opBytes{0x00, 04}}, {AVERW, ydivl, Pm, opBytes{0x00, 05}}, {AWAIT, ynone, Px, opBytes{0x9b}}, {AWORD, ybyte, Px, opBytes{2}}, {AXCHGB, yml_mb, Pb, opBytes{0x86, 0x86}}, {AXCHGL, yxchg, Px, opBytes{0x90, 0x90, 0x87, 0x87}}, {AXCHGQ, yxchg, Pw, opBytes{0x90, 0x90, 0x87, 0x87}},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 15:44:14 UTC 2024 - 146.9K bytes - Viewed (0) -
maven-core/src/test/resources/apiv4-repo/org/hamcrest/hamcrest-core/1.3/hamcrest-core-1.3-javadoc.jar
String start, java.lang.String separator, java.lang.String end, T... values) Appends a list of values to the description. Methods inherited from class java.lang.Object clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait Constructor Detail BaseDescription public BaseDescription() Method Detail appendText public Description appendText(java.lang.String text) Description copied from interface: Description Appends some plain text to the description. Specified by:...
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Sun Oct 02 08:41:25 UTC 2022 - 236.8K bytes - Viewed (0) -
src/database/sql/sql_test.go
opening.Add(tryOpen) setHookOpenErr(func() error { // Wait for all connections to enqueue. opening.Wait() return errOffline }) for i := 0; i < tryOpen; i++ { go func() { opening.Done() // signal one connection is in flight _, err := db.Exec("will never run") errs <- err }() } opening.Wait() // wait for all workers to begin running
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 111.6K bytes - Viewed (0) -
pkg/scheduler/schedule_one_test.go
}) if err != nil { t.Fatal(err) } s.ScheduleOne(ctx) // Wait for pod to succeed or fail scheduling select { case <-eventChan: case <-time.After(wait.ForeverTestTimeout): t.Fatalf("scheduling timeout after %v", wait.ForeverTestTimeout) } stopFunc() // Wait for scheduling to return an error or succeed binding. var ( gotErr error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 128.1K bytes - Viewed (0)