pub async fn acquire<T: Any + Send + Sync>() -> Result<Arc<T>>Expand description
Acquire a value from the pool, if not exists, wait until it is provided. If the value is shutdown while waiting, return error immediately to avoid waiting forever. This function is designed for the scenario that comsumer want to ensure a value is provided and blocking on it. If you want to use it as a subscriber, you may got some value lost in the scenario that the value is frequently provided and comsumer is slow.