Struct libsignal_service::receiver::MessageReceiver

pub struct MessageReceiver<Service> { /* private fields */ }

Equivalent of Java’s SignalServiceMessageReceiver.

Implementations

impl<Service: PushService> MessageReceiver<Service>

pub fn new(service: Service) -> Self

pub async fn retrieve_messages( &mut self, allow_stories: bool, ) -> Result<Vec<Envelope>, ServiceError>

One-off method to receive all pending messages.

Equivalent with Java’s SignalServiceMessageReceiver::retrieveMessages.

For streaming messages, use a MessagePipe through MessageReceiver::create_message_pipe().

pub async fn create_message_pipe( &mut self, credentials: ServiceCredentials, allow_stories: bool, ) -> Result<MessagePipe, ServiceError>

pub async fn retrieve_contacts( &mut self, contacts: &Contacts, ) -> Result<impl Iterator<Item = Result<Contact, ParseContactError>>, ServiceError>

Trait Implementations

impl<Service: Clone> Clone for MessageReceiver<Service>

fn clone(&self) -> MessageReceiver<Service>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.