fn schedule_add_vertices<T>(&mut self, pending_vertices: T) -> ProtocolOutcomes<I, C>
    where
        T: IntoIterator<Item = PendingVertex<I, C>>,
    {
        let was_empty = self.vertices_no_deps.is_empty();
        for pv in pending_vertices {
            self.vertices_no_deps.push(pv);
        }
        if was_empty && !self.vertices_no_deps.is_empty() {
            vec![ProtocolOutcome::QueueAction(ACTION_ID_VERTEX)]
        } else {
            Vec::new()
        }
    }
/// Schedules vertices to be added to the protocol state.
Schedules vertices to be added to the protocol state.
Schedules vertices to be added to the protocol state .
fn schedule_add_vertices<T>(&mut self, pending_vertices: T) -> ProtocolOutcomes<I, C>
    where
        T: IntoIterator<Item = PendingVertex<I, C>>,
    {
        let was_empty = self.vertices_no_deps.is_empty();
        for pv in pending_vertices {
            self.vertices_no_deps.push(pv);
        }
        if was_empty && !self.vertices_no_deps.is_empty() {
            vec![ProtocolOutcome::QueueAction(ACTION_ID_VERTEX)]
        } else {
            Vec::new()
        }
    }
fn schedule_add_vertices < T > ( & mut self , pending_vertices : T ) -> ProtocolOutcomes < I , C > where T : IntoIterator < Item = PendingVertex < I , C > > , { let was_empty = self . vertices_no_deps . is_empty ( ) ; for pv in pending_vertices { self . vertices_no_deps . push ( pv ) ; } if was_empty && ! self . vertices_no_deps . is_empty ( ) { vec ! [ ProtocolOutcome QueueAction ( ACTION_ID_VERTEX ) ] } else { Vec :: new ( ) } }
Schedules vertices to be added to the protocol state.
Schedules vertices to be added to the protocol state .
&mut self
pending_vertices
T
&mut self
pending_vertices
T