Struct PsTopic 

pub struct PsTopic { /* private fields */ }

A struct PsTopic contém o estado e a lógica para um único tópico do pubsub.

Implementations

impl PsTopic

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

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

pub async fn peers_diff(&self) -> Result<(Vec<PeerId>, Vec<PeerId>)>

pub async fn watch_peers_channel( self: &Arc<Self>, ) -> Result<Receiver<Arc<dyn Any + Send + Sync>>>

pub async fn watch_messages(&self) -> Result<Receiver<EventPubSubMessage>>

pub fn topic(&self) -> &str

pub fn cancel(&self)

Cancela todas as operações ativas do tópico

pub fn is_cancelled(&self) -> bool

Verifica se o tópico foi cancelado

pub async fn clear_members(&self)

Limpa a lista de membros do tópico

Trait Implementations

impl PubSubTopic for PsTopic

type Error = GuardianError

fn publish<'life0, 'async_trait>( &'life0 self, message: Vec<u8>, ) -> Pin<Box<dyn Future<Output = Result<()>> + 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>>> + 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>>>> + 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>>>> + 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.