- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 1,033 for isync (0.03 sec)
-
platforms/documentation/docs/src/docs/dsl/org.gradle.api.tasks.Sync.xml
Laura Kassovic <******@****.***> 1701107622 -0800
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Nov 27 17:53:42 UTC 2023 - 795 bytes - Viewed (0) -
tests/test_dependency_class.py
@app.get("/callable-dependency") async def get_callable_dependency(value: str = Depends(callable_dependency)): return value @app.get("/callable-gen-dependency") async def get_callable_gen_dependency(value: str = Depends(callable_gen_dependency)): return value @app.get("/async-callable-dependency") async def get_async_callable_dependency( value: str = Depends(async_callable_dependency), ): return value
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sun Aug 09 10:54:05 UTC 2020 - 3.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/SettableFutureTest.java
async.setFuture(inner); async.cancel(false); assertTrue(inner.isCancelled()); assertFalse(inner.wasInterrupted()); assertThrows(CancellationException.class, () -> inner.get()); } public void testCancel_beforeSet() throws Exception { SettableFuture<Object> async = SettableFuture.create(); async.cancel(true); assertFalse(async.set(42)); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 7.3K bytes - Viewed (0) -
cmd/lock-rest-client.go
r, err := h.Call(ctx, c.connection, args) if err != nil { return false, err } defer h.PutResponse(r) ok = r.Code == dsync.RespOK switch r.Code { case dsync.RespLockConflict, dsync.RespLockNotFound, dsync.RespOK: // no error case dsync.RespLockNotInitialized: err = errLockNotInitialized
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Nov 24 17:07:14 UTC 2023 - 3.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/SettableFutureTest.java
async.setFuture(inner); async.cancel(false); assertTrue(inner.isCancelled()); assertFalse(inner.wasInterrupted()); assertThrows(CancellationException.class, () -> inner.get()); } public void testCancel_beforeSet() throws Exception { SettableFuture<Object> async = SettableFuture.create(); async.cancel(true); assertFalse(async.set(42)); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 7.3K bytes - Viewed (0) -
cmd/lock-rest-server.go
lockRPCRUnlock = newLockHandler(grid.HandlerLockRUnlock) ) func newLockHandler(h grid.HandlerID) *grid.SingleHandler[*dsync.LockArgs, *dsync.LockResp] { return grid.NewSingleHandler[*dsync.LockArgs, *dsync.LockResp](h, func() *dsync.LockArgs { return &dsync.LockArgs{} }, func() *dsync.LockResp { return &dsync.LockResp{} }) } // registerLockRESTHandlers - register lock rest router. func registerLockRESTHandlers() {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Nov 21 01:09:35 UTC 2023 - 5.9K bytes - Viewed (0) -
tensorflow/c/eager/c_api_remote_function_test.cc
namespace { void TestRemoteExecuteSilentCopiesFunc(bool async, bool remote, bool heavy_load_on_streaming_rpc, bool remote_func_outputs = false, bool has_packed_input = false) { return TestRemoteExecuteSilentCopies(async, remote, /*func=*/true, heavy_load_on_streaming_rpc,
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Dec 11 22:56:03 UTC 2020 - 3.6K bytes - Viewed (0) -
tests/test_ws_router.py
async def routerindexparams(websocket: WebSocket, pathparam: str, queryparam: str): 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)
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sun Jun 11 19:08:14 UTC 2023 - 7.5K bytes - Viewed (0) -
tests/test_multipart_installation.py
@app.post("/") async def root(f: bytes = File()): return f # pragma: nocover def test_incorrect_multipart_installed_multi_form(monkeypatch): monkeypatch.delattr("multipart.multipart.parse_options_header", raising=False) with pytest.raises(RuntimeError, match=multipart_incorrect_install_error): app = FastAPI() @app.post("/")
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Fri May 13 23:38:22 UTC 2022 - 3.7K bytes - Viewed (0) -
tests/test_ambiguous_params.py
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Tue Dec 12 00:22:47 UTC 2023 - 2.1K bytes - Viewed (0)