Struct channel2::ChannelChat

pub struct ChannelChat {
    pub channel_id: ChannelId,
    /* private fields */
}

Fields

channel_id: ChannelId

Implementations

impl ChannelChat

pub async fn new( channel: Arc<Channel>, channel_store: Model<ChannelStore>, user_store: Model<UserStore>, client: Arc<Client>, cx: AsyncAppContext ) -> Result<Model<Self>>

pub fn channel(&self, cx: &AppContext) -> Option<Arc<Channel>>

pub fn client(&self) -> &Arc<Client>

pub fn send_message( &mut self, message: MessageParams, cx: &mut ModelContext<'_, Self> ) -> Result<Task<Result<u64>>>

pub fn remove_message( &mut self, id: u64, cx: &mut ModelContext<'_, Self> ) -> Task<Result<()>>

pub fn load_more_messages( &mut self, cx: &mut ModelContext<'_, Self> ) -> Option<Task<Option<()>>>

pub fn first_loaded_message_id(&mut self) -> Option<u64>

pub async fn load_history_since_message( chat: Model<Self>, message_id: u64, cx: AsyncAppContext ) -> Option<usize>

Load all of the chat messages since a certain message id.

For now, we always maintain a suffix of the channel’s messages.

pub fn acknowledge_last_message(&mut self, cx: &mut ModelContext<'_, Self>)

pub fn rejoin(&mut self, cx: &mut ModelContext<'_, Self>)

pub fn message_count(&self) -> usize

pub fn messages(&self) -> &SumTree<ChannelMessage>

pub fn message(&self, ix: usize) -> &ChannelMessage

pub fn acknowledge_message(&mut self, id: u64)

pub fn messages_in_range( &self, range: Range<usize> ) -> impl Iterator<Item = &ChannelMessage>

pub fn pending_messages(&self) -> impl Iterator<Item = &ChannelMessage>

Trait Implementations

impl EventEmitter<ChannelChatEvent> for ChannelChat