Properties

Link copied to clipboard

Whether the current object has been destroyed and its reference is gone in the Rust side.

Functions

Link copied to clipboard
open suspend override fun beginningDeliveryCursor(): String
Link copied to clipboard
open override fun close()
Link copied to clipboard
Link copied to clipboard
open suspend override fun createDm(peer: InboxId, options: CreateDmOptions? = null): Dm
Link copied to clipboard
suspend fun Conversations.createDm(peer: PublicIdentity, options: CreateDmOptions? = null): Dm
Link copied to clipboard
open suspend override fun createGroup(members: List<InboxId>, options: CreateGroupOptions? = null): Group

Find or create a DM with an account identity or a handle. Hosts present this as a createDm overload or union. A handle resolves through the verified handle resolver before the existing DM is looked up.

Link copied to clipboard
suspend fun Conversations.createGroup(members: List<PublicIdentity>, options: CreateGroupOptions? = null): Group
Link copied to clipboard
open suspend override fun createGroupOptimistic(options: CreateGroupOptions? = null): Group
Link copied to clipboard
open suspend override fun deleteMessage(id: MessageId): MessageId

Create a group from account identities and handles. Hosts present this as a createGroup overload or union. Every handle resolves through the verified handle resolver before the group exists, and all members join in one commit.

Link copied to clipboard
open suspend override fun deleteMessageLocally(id: MessageId)
Link copied to clipboard
open override fun destroy()
Link copied to clipboard
open suspend override fun getById(id: ConversationId): Conversation?
Link copied to clipboard
open suspend override fun getDmByIdentity(identity: PublicIdentity): Dm?

The DM with an account or a handle, or None. A handle resolves through the verified handle resolver before the DM is looked up.

Link copied to clipboard
open suspend override fun getDmByInboxId(peer: InboxId): Dm?
Link copied to clipboard
open suspend override fun getMessageById(id: MessageId): Message?
Link copied to clipboard
open suspend override fun hmacKeys(): Map<String, List<HmacKey>>
Link copied to clipboard
open suspend override fun list(options: ListConversationsOptions? = null): List<Conversation>
Link copied to clipboard
open suspend override fun listDms(options: ListConversationsOptions?): List<Dm>
Link copied to clipboard
open suspend override fun listGroups(options: ListConversationsOptions?): List<Group>
Link copied to clipboard
open suspend override fun messageHistorySnapshot(limit: UInt, options: MessageReaderOptions? = null): MessageHistorySnapshot

Capture history with kind and consent selection. A replay from cursor is invalid because this call captures a new atomic replay boundary.

Link copied to clipboard
open suspend override fun messageReader(options: MessageReaderOptions? = null): MessageReader
Link copied to clipboard
open suspend override fun reactToMessage(id: MessageId, reaction: Reaction, options: SendOptions? = null): MessageId
Link copied to clipboard
open suspend override fun replyToMessage(id: MessageId, content: EncodedContent, options: SendOptions? = null): MessageId
Link copied to clipboard
fun Conversations.stream(options: ConversationStreamOptions = ConversationStreamOptions()): Flow<Conversation>

This cold Flow holds its client. Each collection opens a conversation reader.

Link copied to clipboard
fun Conversations.streamAllMessages(options: MessageStreamOptions = MessageStreamOptions()): Flow<Message>

This cold Flow holds its client before and between collections. Each collection opens a reader. With direct sequential collection, the next read acknowledges the previous message after the collector returns. A buffer or asynchronous operator can let acknowledgement start before downstream work finishes. Cancellation cannot undo an acknowledgement that has started.

Link copied to clipboard
open suspend override fun sync()

Host stream ownership.

Link copied to clipboard
open suspend override fun syncAll(consentStates: List<ConsentState>?): GroupSyncSummary