Struct MessageServiceClient 

pub struct MessageServiceClient<Stub = Channel<MessageServiceRequest, MessageServiceResponse>>(Stub);

The client stub that makes RPC calls to the server. All request methods return Futures.

Tuple Fields

0: Stub

Implementations

impl MessageServiceClient

pub fn new<T>( config: Config, transport: T, ) -> NewClient<Self, RequestDispatch<MessageServiceRequest, MessageServiceResponse, T>>

where T: Transport<ClientMessage<MessageServiceRequest>, Response<MessageServiceResponse>>,

Returns a new client stub that sends requests over the given transport.

impl<Stub> MessageServiceClient<Stub>

where Stub: Stub<Req = MessageServiceRequest, Resp = MessageServiceResponse>,

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<Stub: Clone> Clone for MessageServiceClient<Stub>

fn clone(&self) -> MessageServiceClient<Stub>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Stub: Debug> Debug for MessageServiceClient<Stub>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<Stub> From<Stub> for MessageServiceClient<Stub>

where Stub: Stub<Req = MessageServiceRequest, Resp = MessageServiceResponse>,

fn from(stub: Stub) -> Self

Returns a new client stub that sends requests over the given transport.