Struct PoolSpawner 

pub struct PoolSpawner { /* private fields */ }

Implementations

impl PoolSpawner

pub fn new(config: PoolPeerConfig, network_wait_period: Duration) -> PoolSpawner

pub async fn fill_pool( &mut self, action_tx: &Sender<SpawnEvent>, ) -> Result<(), PoolSpawnError>

Trait Implementations

impl BasicSpawner for PoolSpawner

type Error = PoolSpawnError

fn handle_init<'life0, 'life1, 'async_trait>( &'life0 mut self, action_tx: &'life1 Sender<SpawnEvent>, ) -> Pin<Box<dyn Future<Output = Result<(), PoolSpawnError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Handle initial spawning.

fn handle_peer_removed<'life0, 'life1, 'async_trait>( &'life0 mut self, removed_peer: PeerRemovedEvent, action_tx: &'life1 Sender<SpawnEvent>, ) -> Pin<Box<dyn Future<Output = Result<(), PoolSpawnError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Event handler for when a peer is removed.

fn get_id(&self) -> SpawnerId

Get the id of the spawner

fn get_addr_description(&self) -> String

Get a description of the address this spawner is connected to

fn get_description(&self) -> &str

Get a description of the type of spawner

fn handle_registered<'life0, 'life1, 'async_trait>( &'life0 mut self, _event: PeerCreateParameters, _action_tx: &'life1 Sender<SpawnEvent>, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

where Self: Send + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Event handler for when a peer is succesfully registered in the system