Struct IrohTopic 

pub struct IrohTopic { /* private fields */ }

Implementação de PubSubTopic para Iroh com Gossipsub

Implementations

impl IrohTopic

pub async fn publish(&self, data: &[u8]) -> Result<()>

Publica mensagem no tópico

pub fn subscribe_messages(&self) -> Receiver<Vec<u8>>

Cria um receiver para mensagens do tópico

pub async fn notify_message(&self, data: Vec<u8>) -> Result<()>

Notifica sobre mensagem recebida (chamado pelo event loop do SwarmManager)

pub async fn add_peer(&self, peer_id: PeerId)

Adiciona peer ao tópico

pub async fn remove_peer(&self, peer_id: &PeerId)

Remove peer do tópico

pub async fn list_peers(&self) -> Vec<PeerId>

Lista peers conectados ao tópico

Trait Implementations

impl PubSubTopic for IrohTopic

type Error = GuardianError

fn publish<'life0, 'async_trait>( &'life0 self, message: Vec<u8>, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Publica uma nova mensagem no tópico.

fn peers<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<PeerId>, Self::Error>> + Send + 'async_trait>>

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

Lista os pares (peers) conectados a este tópico.

fn watch_peers<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Event> + Send>>, Self::Error>> + Send + 'async_trait>>

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

Observa os pares que entram e saem do tópico.

fn watch_messages<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = EventPubSubMessage> + Send>>, Self::Error>> + Send + 'async_trait>>

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

Observa as novas mensagens publicadas no tópico.

fn topic(&self) -> &str

Retorna o nome do tópico.