fn on_user_ingress(
        &self,
        ingress: Self::Ingress,
        peer_id: Self::NodeId,
    ) -> Result<(), OnArtifactError<Artifact>> {
        let advert = IngressArtifact::message_to_advert(&ingress);
        self.artifact_manager
            .on_artifact(
                Artifact::IngressMessage(ingress.into()),
                advert.into(),
                &peer_id,
            )
            .map_err(|e| {
                info!(self.log, "Artifact not inserted {:?}", e);
                e
            })
    }
/// The method handles the received user ingress message.
The method handles the received user ingress message.
The method handles the received user ingress message .
fn on_user_ingress(
        &self,
        ingress: Self::Ingress,
        peer_id: Self::NodeId,
    ) -> Result<(), OnArtifactError<Artifact>> {
        let advert = IngressArtifact::message_to_advert(&ingress);
        self.artifact_manager
            .on_artifact(
                Artifact::IngressMessage(ingress.into()),
                advert.into(),
                &peer_id,
            )
            .map_err(|e| {
                info!(self.log, "Artifact not inserted {:?}", e);
                e
            })
    }
fn on_user_ingress ( & self , ingress : Self :: Ingress , peer_id : Self :: NodeId , ) -> Result < ( ) , OnArtifactError < Artifact > > { let advert = IngressArtifact :: message_to_advert ( & ingress ) ; self . artifact_manager . on_artifact ( Artifact :: IngressMessage ( ingress . into ( ) ) , advert . into ( ) , & peer_id , ) . map_err ( | e | { info ! ( self log " " e ) ; e } ) }
The method handles the received user ingress message.
The method handles the received user ingress message .
&self
ingress
Self::Ingress
peer_id
Self::NodeId
&self
ingress
Self::Ingress
peer_id
Self::NodeId