MCPcopy Index your code
hub / github.com/ray-project/ray / wait

Method wait

java/api/src/main/java/io/ray/api/runtime/RayRuntime.java:97–97  ·  view source on GitHub ↗

Wait for a list of RayObjects to be available, until specified number of objects are ready, or specified timeout has passed. @param waitList A list of ObjectRef to wait for. @param numReturns The number of objects that should be returned. @param timeoutMs The maximum time in milliseconds to wait be

(
      List<ObjectRef<T>> waitList, int numReturns, int timeoutMs, boolean fetchLocal)

Source from the content-addressed store, hash-verified

95 * @return Two lists, one containing locally available objects, one containing the rest.
96 */
97 <T> WaitResult<T> wait(
98 List<ObjectRef<T>> waitList, int numReturns, int timeoutMs, boolean fetchLocal);
99
100 /**

Callers 15

waitMethod · 0.65
mock_serverFunction · 0.65
streamMethod · 0.65
run_interactiveFunction · 0.65
run_rate_based_benchmarkFunction · 0.65
_run_eviction_loopMethod · 0.65
wait_for_batchMethod · 0.65
_direct_ingress_asgiMethod · 0.65
mock_receiveFunction · 0.65

Implementers 1

AbstractRayRuntimejava/runtime/src/main/java/io/ray/runt

Calls

no outgoing calls

Tested by 15

waitMethod · 0.52
mock_serverFunction · 0.52
__anext__Method · 0.52
get_queue_lenMethod · 0.52
waitMethod · 0.52
waitMethod · 0.52
run_testMethod · 0.52
test_host_standaloneFunction · 0.52
test_client_threadsafeFunction · 0.52