Method start

syncer/src/actor.rs:378–398

Start the actor.

(
        mut self,
        application: impl Reporter<Activity = Update<B, P::Scheme, A>>,
        buffer: buffered::Mailbox<K, B>,
        resolver: (mpsc::Receiver<handler::Message<B::Digest>>, R),

                Self {
                    context: ContextCell::new(context),
                    mailbox,
                    provider: config.scheme_provider,
                    epocher: config.epocher,
                    view_retention_timeout: config.view_retention_timeout,
                    max_repair: config.max_repair,
                    block_codec_config: config.block_codec_config,
                    strategy: config.strategy,
                    last_processed_round: Round::zero(),
                    last_processed_height: Height::zero(),
                    pending_acks: PendingAcks::new(config.max_pending_acks.get()),
                    tip: Height::zero(),
                    block_subscriptions: BTreeMap::new(),
                    cache,
                    application_metadata,
                    finalizations_by_height,
                    finalized_blocks,
                },
                Mailbox::new(sender),
            )
        }
    }

    /// Start the actor.
    pub fn start<R, K>(