Struct MessageService 

pub struct MessageService<'a> { /* private fields */ }

Implementations

impl<'a> MessageService<'a>

pub fn send(&self, request: SendMessageRequest) -> ImResult<SendMessageResult>

pub async fn send_async( &self, request: SendMessageRequest, ) -> ImResult<SendMessageResult>

pub async fn send_conversation_text_async( &self, request: SendConversationTextRequest, ) -> ImResult<SendMessageResult>

pub async fn send_conversation_payload_async( &self, request: SendConversationPayloadRequest, ) -> ImResult<SendMessageResult>

pub fn inbox(&self, query: InboxQuery) -> ImResult<Page<Message>>

pub async fn inbox_async(&self, query: InboxQuery) -> ImResult<Page<Message>>

pub fn inbox_with_metadata(&self, query: InboxQuery) -> ImResult<MessagePage>

pub async fn inbox_with_metadata_async( &self, query: InboxQuery, ) -> ImResult<MessagePage>

pub fn history( &self, thread: ThreadRef, query: HistoryQuery, ) -> ImResult<Page<Message>>

pub async fn history_async( &self, thread: ThreadRef, query: HistoryQuery, ) -> ImResult<Page<Message>>

pub fn history_with_metadata( &self, thread: ThreadRef, query: HistoryQuery, ) -> ImResult<MessagePage>

pub async fn history_with_metadata_async( &self, thread: ThreadRef, query: HistoryQuery, ) -> ImResult<MessagePage>

pub fn local_history( &self, thread: ThreadRef, query: LocalHistoryQuery, ) -> ImResult<Page<Message>>

pub async fn local_history_async( &self, thread: ThreadRef, query: LocalHistoryQuery, ) -> ImResult<Page<Message>>

pub fn local_history_with_metadata( &self, thread: ThreadRef, query: LocalHistoryQuery, ) -> ImResult<MessagePage>

pub async fn local_history_with_metadata_async( &self, thread: ThreadRef, query: LocalHistoryQuery, ) -> ImResult<MessagePage>

pub fn local_conversation_timeline( &self, conversation: ConversationReadRef, query: LocalHistoryQuery, ) -> ImResult<Page<Message>>

pub async fn local_conversation_timeline_async( &self, conversation: ConversationReadRef, query: LocalHistoryQuery, ) -> ImResult<Page<Message>>

pub fn local_conversation_timeline_with_metadata( &self, conversation: ConversationReadRef, query: LocalHistoryQuery, ) -> ImResult<MessagePage>

pub async fn local_conversation_timeline_with_metadata_async( &self, conversation: ConversationReadRef, query: LocalHistoryQuery, ) -> ImResult<MessagePage>

pub fn mark_read(&self, ids: Vec<MessageId>) -> ImResult<MarkReadResult>

pub async fn mark_read_async( &self, ids: Vec<MessageId>, ) -> ImResult<MarkReadResult>

pub fn mark_thread_read( &self, request: MarkThreadReadRequest, ) -> ImResult<MarkThreadReadResult>

pub async fn mark_thread_read_async( &self, request: MarkThreadReadRequest, ) -> ImResult<MarkThreadReadResult>

pub fn mark_conversation_read( &self, request: MarkConversationReadRequest, ) -> ImResult<MarkThreadReadResult>

pub async fn mark_conversation_read_async( &self, request: MarkConversationReadRequest, ) -> ImResult<MarkThreadReadResult>

pub fn sync_thread_after( &self, request: SyncThreadAfterRequest, ) -> ImResult<SyncThreadAfterResult>

pub async fn sync_thread_after_async( &self, request: SyncThreadAfterRequest, ) -> ImResult<SyncThreadAfterResult>

pub fn sync_conversation_after( &self, request: SyncConversationAfterRequest, ) -> ImResult<SyncThreadAfterResult>

pub async fn sync_conversation_after_async( &self, request: SyncConversationAfterRequest, ) -> ImResult<SyncThreadAfterResult>

pub fn sync_delta(&self, request: SyncDeltaRequest) -> ImResult<SyncDeltaResult>

pub async fn sync_delta_async( &self, request: SyncDeltaRequest, ) -> ImResult<SyncDeltaResult>

pub fn conversations( &self, query: ConversationQuery, ) -> ImResult<Page<Conversation>>

pub async fn conversations_async( &self, query: ConversationQuery, ) -> ImResult<Page<Conversation>>

pub fn load_conversation_snapshot( &self, ) -> ImResult<Option<ConversationListSnapshot>>

pub async fn load_conversation_snapshot_async( &self, ) -> ImResult<Option<ConversationListSnapshot>>

pub fn clear_conversation_snapshot(&self) -> ImResult<()>

pub async fn clear_conversation_snapshot_async(&self) -> ImResult<()>

pub fn watch_conversation_patches(&self) -> ImResult<ConversationPatchSession>

pub async fn watch_conversation_patches_async( &self, ) -> ImResult<ConversationPatchSession>

pub fn repair_conversation_store(&self) -> ImResult<ConversationStorePatch>

pub async fn repair_conversation_store_async( &self, ) -> ImResult<ConversationStorePatch>

pub fn watch_thread_patches( &self, thread: ThreadRef, limit: Option<u32>, ) -> ImResult<ThreadMessagePatchSession>

pub async fn watch_thread_patches_async( &self, thread: ThreadRef, limit: Option<u32>, ) -> ImResult<ThreadMessagePatchSession>

pub fn watch_conversation_timeline_patches( &self, conversation: ConversationReadRef, limit: Option<u32>, ) -> ImResult<ThreadMessagePatchSession>

pub async fn watch_conversation_timeline_patches_async( &self, conversation: ConversationReadRef, limit: Option<u32>, ) -> ImResult<ThreadMessagePatchSession>

pub fn repair_thread_store( &self, thread: ThreadRef, limit: Option<u32>, ) -> ImResult<ThreadMessageStorePatch>

pub async fn repair_thread_store_async( &self, thread: ThreadRef, limit: Option<u32>, ) -> ImResult<ThreadMessageStorePatch>

pub fn repair_conversation_timeline_store( &self, conversation: ConversationReadRef, limit: Option<u32>, ) -> ImResult<ThreadMessageStorePatch>

pub async fn repair_conversation_timeline_store_async( &self, conversation: ConversationReadRef, limit: Option<u32>, ) -> ImResult<ThreadMessageStorePatch>