Struct MessagesService 

pub struct MessagesService {
    rpc_client: MessageServiceClient,
    handle: JoinHandle<Result<()>>,
}

Fields

rpc_client: MessageServiceClient

handle: JoinHandle<Result<()>>

Implementations

impl MessagesService

pub async fn connect( connection: &Connection, ) -> Result<(Self, (MessagesStream, CatchUpStream))>

pub async fn subscribe(&self, filters: SubscriptionConfig) -> Result<()>

pub async fn update_filters( &self, request: FilterUpdateRequest, ) -> Result<SubscriptionConfig>

pub async fn catch_up( &self, request: CatchUpRequest, ) -> Result<SubscriptionConfig>

pub fn is_closed(&self) -> bool

Check if the service is closed

Methods from Deref<Target = MessageServiceClient>

pub fn publish( &self, ctx: Context, message: MessageFull, ) -> impl Future<Output = Result<Result<PublishResult, MessageError>, RpcError>>

pub fn message( &self, ctx: Context, id: MessageId, ) -> impl Future<Output = Result<Result<Option<MessageFull>, MessageError>, RpcError>>

Retrieve a specific message by its ID

pub fn user_data( &self, ctx: Context, author: KeyId, storage_key: StoreKey, ) -> impl Future<Output = Result<Result<Option<MessageFull>, MessageError>, RpcError>>

Retrieve a specific user’s data by their key and storage key

pub fn check_messages( &self, ctx: Context, message_ids: Vec<MessageId>, ) -> impl Future<Output = Result<Result<Vec<Option<String>>, MessageError>, RpcError>>

Check which messages the server already has and return their global stream IDs. Returns a vec of Option<String> in the same order as the input, where:

• Some(stream_id) means the server has the message with that global stream ID
• None means the server doesn’t have this message yet

pub fn subscribe( &self, ctx: Context, config: SubscriptionConfig, ) -> impl Future<Output = Result<Result<(), MessageError>, RpcError>>

Start the subscription

pub fn update_filters( &self, ctx: Context, request: FilterUpdateRequest, ) -> impl Future<Output = Result<Result<SubscriptionConfig, MessageError>, RpcError>>

Update the running subscription filters with the actions. Returns the now final subscription config.

pub fn catch_up( &self, ctx: Context, request: CatchUpRequest, ) -> impl Future<Output = Result<Result<SubscriptionConfig, MessageError>, RpcError>>

Update the internal subscription and catch up to the latest stream height for the given filter

Trait Implementations

impl Deref for MessagesService

type Target = MessageServiceClient

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.