pub async fn get_existing_resources<C: Update + Default>(
stream: impl Stream<Item = Result<Event, WatchError>>,
) -> Result<C, GetExistingResourcesError>
Expand description
Collects all existing
events from the stream, stopping once the idle
event is observed.