event_stream_from_iterator

Function event_stream_from_iterator 

Source
pub fn event_stream_from_iterator(
    neighbor_iterator: EntryIteratorProxy,
) -> impl Stream<Item = Result<Event, EntryIteratorError>>
Expand description

Turns the provided neighbor table entry iterator into an Event stream by applying Hanging-Get watch.

Each call to GetNext returns a batch of events, which are flattened into a single stream. If an error is encountered while calling GetNext or while converting the event, the stream is immediately terminated.