pub async fn collect_neighbors_until_idle<C: Extend<Entry> + Default>(
event_stream: impl Stream<Item = Result<Event, EntryIteratorError>> + Unpin,
) -> Result<C, CollectNeighborsUntilIdleError>Expand description
Collects all existing events from the stream, stopping once the idle
event is observed.