collect_neighbors_until_idle

Function collect_neighbors_until_idle 

Source
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.