- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 2,355 for nwait (0.06 sec)
-
misc/wasm/wasm_exec.html
--> <script src="wasm_exec.js"></script> <script> if (!WebAssembly.instantiateStreaming) { // polyfill WebAssembly.instantiateStreaming = async (resp, importObject) => { const source = await (await resp).arrayBuffer(); return await WebAssembly.instantiate(source, importObject); }; } const go = new Go(); let mod, inst; WebAssembly.instantiateStreaming(fetch("test.wasm"), go.importObject).then((result) => {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Oct 02 17:25:11 UTC 2018 - 1.3K bytes - Viewed (0) -
tensorflow/compiler/mlir/tfrt/tests/mlrt/fuse_mlrt_ops.mlir
// CHECK-NOT: tf_mlrt.await // CHECK-NEXT: [[t2:%.*]] = tf_mlrt.executeop([[t]]#0, [[t]]#1) // CHECK-NEXT: [[t3:%.*]] = tf_mlrt.await [[f2]] // CHECK-NEXT: return [[t2]], [[t3]] %t0 = tf_mlrt.await %f0 %t1 = tf_mlrt.await %f1 %t2 = tf_mlrt.executeop(%t0, %t1) {node_def = "AddV2", op_key = 0 : i32} : (!tf_mlrt.tensor, !tf_mlrt.tensor) -> (!tf_mlrt.tensor) %t3 = tf_mlrt.await %f2
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Jul 07 23:57:30 UTC 2023 - 3K bytes - Viewed (0) -
docs_src/websockets/tutorial003.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: Sun Aug 09 13:52:19 UTC 2020 - 2.5K bytes - Viewed (0) -
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: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Wed Oct 18 12:36:40 UTC 2023 - 2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/waitgroup/ratelimited_waitgroup.go
wg sync.WaitGroup // Once Wait is initiated, all consecutive Done invocation will be // rate limited using this rate limiter. limiter RateLimiter stopCtx context.Context mu sync.Mutex // wait indicate whether Wait is called, if true, // then any Add with positive delta will return error. wait bool // number of request(s) currently using the wait group count int }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 21 14:08:00 UTC 2023 - 3.7K bytes - Viewed (0) -
.github/workflows/trusted-partners.yml
const username = context.payload.pull_request.user.login; const domain = await script.get_email_domain({github, username}); switch(domain) { case "intel.com": console.log(await script.filter({github, context, domain})); break; case "apple.com": console.log(await script.filter({github, context, domain})); break; case "nvidia.com":
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Sep 12 14:49:29 UTC 2023 - 2.4K bytes - Viewed (0) -
pkg/kubelet/config/file_linux_test.go
file = testCase.writeToFile(dirName, fileName, t) }() if watchDir { NewSourceFile(dirName, hostname, period, ch) } else { NewSourceFile(file, hostname, period, ch) } // await fsnotify to be ready time.Sleep(time.Second) // expect an update by SourceFile.resetStoreFromPath() expectUpdate(t, ch, testCase) pod := testCase.pod.(*v1.Pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 14 09:38:23 UTC 2022 - 12.3K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/waitgroup/ratelimited_waitgroup_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 21 14:08:00 UTC 2023 - 8.6K bytes - Viewed (0) -
istioctl/pkg/wait/wait_test.go
cmd.SetErr(&out) fErr := cmd.Execute() output := out.String() if c.expectedOutput != "" && !strings.Contains(output, c.expectedOutput) { t.Fatalf("Unexpected output for 'istioctl %s'\n got: %q\nwant: %q", strings.Join(c.args, " "), output, c.expectedOutput) } if c.wantException { if fErr == nil { t.Fatalf("Wanted an exception for 'istioctl %s', didn't get one, output was %q",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 15 08:28:50 UTC 2024 - 6.8K bytes - Viewed (0) -
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)