Bounded deref for milvus-clj RPC futures. Replaces bare @(milvus/...);
on timeout throws a :milvus/timeout-tagged ex-info.
Bounded deref for milvus-clj RPC futures. Replaces bare `@(milvus/...)`; on timeout throws a `:milvus/timeout`-tagged ex-info.
(deref! op fut)(deref! op fut ms)Deref fut within ms (default timeout-ms). Returns the value, or
throws a :milvus/timeout-tagged ex-info on timeout. op labels the call.
A java.util.concurrent.Future (what milvus-clj returns) goes through
hive-weave's deref-safe; any other blocking deref (a promise) gets a timed
deref; a plain IDeref such as a test stub's delay has no timeout form
and is dereferenced directly.
Deref `fut` within `ms` (default `timeout-ms`). Returns the value, or throws a `:milvus/timeout`-tagged ex-info on timeout. `op` labels the call. A `java.util.concurrent.Future` (what milvus-clj returns) goes through hive-weave's deref-safe; any other blocking deref (a promise) gets a timed `deref`; a plain IDeref such as a test stub's `delay` has no timeout form and is dereferenced directly.
(timeout-ms)RPC-deref budget in ms. Env MILVUS_DEREF_TIMEOUT_MS, else 5000.
RPC-deref budget in ms. Env MILVUS_DEREF_TIMEOUT_MS, else 5000.
cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |