Struct fuel_core_sync::import::Import

pub struct Import<P, E, C> { /* private fields */ }

The combination of shared state, configuration, and services that define import behavior.

Implementations

impl<P, E, C> Import<P, E, C>

pub fn new( state: SharedMutex<State>, notify: Arc<Notify>, params: Config, p2p: Arc<P>, executor: Arc<E>, consensus: Arc<C>, ) -> Self

Configure an import behavior from a shared state, configuration and services that can be executed by an ImportTask.

pub fn notify_one(&self)

Signal other asynchronous tasks that an import event has occurred.

impl<P, E, C> Import<P, E, C>

where P: PeerToPeerPort + Send + Sync + 'static, E: BlockImporterPort + Send + Sync + 'static, C: ConsensusPort + Send + Sync + 'static,

pub async fn import(&self, shutdown: &mut StateWatcher) -> Result<bool>

Execute imports until a shutdown is requested.