pub fn new_from_events<I: IntoIterator<Item = HistoryEvent>>(
        events: I,
        previous_wft_started_id: i64,
    ) -> Self
    where
        <I as IntoIterator>::IntoIter: Send + 'static,
    {
        Self {
            events: stream::iter(events.into_iter().map(Ok)).boxed(),
            buffered: VecDeque::new(),
            previous_started_event_id: previous_wft_started_id,
        }
    }
/// Create an instance of an update directly from events - should only be used for replaying.
Create an instance of an update directly from events - should only be used for replaying.
Create an instance of an update directly from events - should only be used for replaying .
pub fn new_from_events<I: IntoIterator<Item = HistoryEvent>>(
        events: I,
        previous_wft_started_id: i64,
    ) -> Self
    where
        <I as IntoIterator>::IntoIter: Send + 'static,
    {
        Self {
            events: stream::iter(events.into_iter().map(Ok)).boxed(),
            buffered: VecDeque::new(),
            previous_started_event_id: previous_wft_started_id,
        }
    }
pub fn new_from_events < I : IntoIterator < Item = HistoryEvent > > ( events : I , previous_wft_started_id : i64 , ) -> Self where < I as IntoIterator > :: IntoIter : Send + ' static , { Self { events : stream :: iter ( events . into_iter ( ) . map ( Ok ) ) . boxed ( ) , buffered : VecDeque :: new ( ) , previous_started_event_id : previous_wft_started_id , } }
Create an instance of an update directly from events - should only be used for replaying.
Create an instance of an update directly from events - should only be used for replaying .
events
I
previous_wft_started_id
i64
events
I
previous_wft_started_id
i64