pub struct ImInterfaceClient<T> { /* private fields */ }Expand description
Implementations§
Source§impl<T> ImInterfaceClient<T>where
T: GrpcService<BoxBody>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
impl<T> ImInterfaceClient<T>where
T: GrpcService<BoxBody>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
pub fn new(inner: T) -> Self
pub fn with_origin(inner: T, origin: Uri) -> Self
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> ImInterfaceClient<InterceptedService<T, F>>where
F: Interceptor,
T::ResponseBody: Default,
T: Service<Request<BoxBody>, Response = Response<<T as GrpcService<BoxBody>>::ResponseBody>>,
<T as Service<Request<BoxBody>>>::Error: Into<StdError> + Send + Sync,
Sourcepub fn send_compressed(self, encoding: CompressionEncoding) -> Self
pub fn send_compressed(self, encoding: CompressionEncoding) -> Self
Compress requests with the given encoding.
This requires the server to support it otherwise it might respond with an error.
Sourcepub fn accept_compressed(self, encoding: CompressionEncoding) -> Self
pub fn accept_compressed(self, encoding: CompressionEncoding) -> Self
Enable decompressing responses.
Sourcepub fn max_decoding_message_size(self, limit: usize) -> Self
pub fn max_decoding_message_size(self, limit: usize) -> Self
Limits the maximum size of a decoded message.
Default: 4MB
Sourcepub fn max_encoding_message_size(self, limit: usize) -> Self
pub fn max_encoding_message_size(self, limit: usize) -> Self
Limits the maximum size of an encoded message.
Default: usize::MAX
Sourcepub async fn ack_assis_msg(
&mut self,
request: impl IntoRequest<ReqAckAssisMsg>,
) -> Result<Response<DummyRsp>, Status>
pub async fn ack_assis_msg( &mut self, request: impl IntoRequest<ReqAckAssisMsg>, ) -> Result<Response<DummyRsp>, Status>
Sourcepub async fn ack_sessions(
&mut self,
request: impl IntoRequest<ReqAckSessions>,
) -> Result<Response<RspSessions>, Status>
pub async fn ack_sessions( &mut self, request: impl IntoRequest<ReqAckSessions>, ) -> Result<Response<RspSessions>, Status>
Sourcepub async fn batch_get_msg_detail(
&mut self,
request: impl IntoRequest<ReqGetMsg>,
) -> Result<Response<RspGetMsg>, Status>
pub async fn batch_get_msg_detail( &mut self, request: impl IntoRequest<ReqGetMsg>, ) -> Result<Response<RspGetMsg>, Status>
Sourcepub async fn batch_rm_dustbin(
&mut self,
request: impl IntoRequest<DummyReq>,
) -> Result<Response<DummyRsp>, Status>
pub async fn batch_rm_dustbin( &mut self, request: impl IntoRequest<DummyReq>, ) -> Result<Response<DummyRsp>, Status>
Sourcepub async fn batch_rm_sessions(
&mut self,
request: impl IntoRequest<ReqBatRmSess>,
) -> Result<Response<DummyRsp>, Status>
pub async fn batch_rm_sessions( &mut self, request: impl IntoRequest<ReqBatRmSess>, ) -> Result<Response<DummyRsp>, Status>
Sourcepub async fn batch_sess_detail(
&mut self,
request: impl IntoRequest<ReqSessionDetails>,
) -> Result<Response<RspSessionDetails>, Status>
pub async fn batch_sess_detail( &mut self, request: impl IntoRequest<ReqSessionDetails>, ) -> Result<Response<RspSessionDetails>, Status>
Sourcepub async fn batch_update_dustbin_ack(
&mut self,
request: impl IntoRequest<DummyReq>,
) -> Result<Response<DummyRsp>, Status>
pub async fn batch_update_dustbin_ack( &mut self, request: impl IntoRequest<DummyReq>, ) -> Result<Response<DummyRsp>, Status>
Sourcepub async fn close_clear_unread_ui(
&mut self,
request: impl IntoRequest<ReqCloseClearUnreadUi>,
) -> Result<Response<RspCloseClearUnreadUi>, Status>
pub async fn close_clear_unread_ui( &mut self, request: impl IntoRequest<ReqCloseClearUnreadUi>, ) -> Result<Response<RspCloseClearUnreadUi>, Status>
Sourcepub async fn get_discuss_list_in_im_page(
&mut self,
request: impl IntoRequest<ReqGetDiscussListInImPage>,
) -> Result<Response<RspGetDiscussListInImPage>, Status>
pub async fn get_discuss_list_in_im_page( &mut self, request: impl IntoRequest<ReqGetDiscussListInImPage>, ) -> Result<Response<RspGetDiscussListInImPage>, Status>
Sourcepub async fn get_live_info(
&mut self,
request: impl IntoRequest<ReqLiveInfo>,
) -> Result<Response<RspLiveInfo>, Status>
pub async fn get_live_info( &mut self, request: impl IntoRequest<ReqLiveInfo>, ) -> Result<Response<RspLiveInfo>, Status>
Sourcepub async fn get_sessions(
&mut self,
request: impl IntoRequest<ReqGetSessions>,
) -> Result<Response<RspSessions>, Status>
pub async fn get_sessions( &mut self, request: impl IntoRequest<ReqGetSessions>, ) -> Result<Response<RspSessions>, Status>
Sourcepub async fn get_specific_sessions(
&mut self,
request: impl IntoRequest<ReqGetSpecificSessions>,
) -> Result<Response<RspSessions>, Status>
pub async fn get_specific_sessions( &mut self, request: impl IntoRequest<ReqGetSpecificSessions>, ) -> Result<Response<RspSessions>, Status>
Sourcepub async fn get_total_unread(
&mut self,
request: impl IntoRequest<ReqTotalUnread>,
) -> Result<Response<RspTotalUnread>, Status>
pub async fn get_total_unread( &mut self, request: impl IntoRequest<ReqTotalUnread>, ) -> Result<Response<RspTotalUnread>, Status>
Sourcepub async fn get_user_cosmo_state(
&mut self,
request: impl IntoRequest<GetUserCosmoStateReq>,
) -> Result<Response<GetUserCosmoStateRsp>, Status>
pub async fn get_user_cosmo_state( &mut self, request: impl IntoRequest<GetUserCosmoStateReq>, ) -> Result<Response<GetUserCosmoStateRsp>, Status>
Sourcepub async fn group_assis_msg(
&mut self,
request: impl IntoRequest<ReqGroupAssisMsg>,
) -> Result<Response<RspSessionMsg>, Status>
pub async fn group_assis_msg( &mut self, request: impl IntoRequest<ReqGroupAssisMsg>, ) -> Result<Response<RspSessionMsg>, Status>
Sourcepub async fn like_msg(
&mut self,
request: impl IntoRequest<ReqLikeMsg>,
) -> Result<Response<DummyRsp>, Status>
pub async fn like_msg( &mut self, request: impl IntoRequest<ReqLikeMsg>, ) -> Result<Response<DummyRsp>, Status>
Sourcepub async fn msg_has_like(
&mut self,
request: impl IntoRequest<ReqMsgHasLike>,
) -> Result<Response<RspMsgHasLike>, Status>
pub async fn msg_has_like( &mut self, request: impl IntoRequest<ReqMsgHasLike>, ) -> Result<Response<RspMsgHasLike>, Status>
Sourcepub async fn my_group_unread(
&mut self,
request: impl IntoRequest<DummyReq>,
) -> Result<Response<RspMyGroupUnread>, Status>
pub async fn my_group_unread( &mut self, request: impl IntoRequest<DummyReq>, ) -> Result<Response<RspMyGroupUnread>, Status>
Sourcepub async fn new_sessions(
&mut self,
request: impl IntoRequest<ReqNewSessions>,
) -> Result<Response<RspSessions>, Status>
pub async fn new_sessions( &mut self, request: impl IntoRequest<ReqNewSessions>, ) -> Result<Response<RspSessions>, Status>
Sourcepub async fn remove_session(
&mut self,
request: impl IntoRequest<ReqRemoveSession>,
) -> Result<Response<DummyRsp>, Status>
pub async fn remove_session( &mut self, request: impl IntoRequest<ReqRemoveSession>, ) -> Result<Response<DummyRsp>, Status>
Sourcepub async fn send_msg(
&mut self,
request: impl IntoRequest<ReqSendMsg>,
) -> Result<Response<RspSendMsg>, Status>
pub async fn send_msg( &mut self, request: impl IntoRequest<ReqSendMsg>, ) -> Result<Response<RspSendMsg>, Status>
Sourcepub async fn session_detail(
&mut self,
request: impl IntoRequest<ReqSessionDetail>,
) -> Result<Response<SessionInfo>, Status>
pub async fn session_detail( &mut self, request: impl IntoRequest<ReqSessionDetail>, ) -> Result<Response<SessionInfo>, Status>
Sourcepub async fn set_top(
&mut self,
request: impl IntoRequest<ReqSetTop>,
) -> Result<Response<DummyRsp>, Status>
pub async fn set_top( &mut self, request: impl IntoRequest<ReqSetTop>, ) -> Result<Response<DummyRsp>, Status>
Sourcepub async fn show_clear_unread_ui(
&mut self,
request: impl IntoRequest<ReqShowClearUnreadUi>,
) -> Result<Response<RspShowClearUnreadUi>, Status>
pub async fn show_clear_unread_ui( &mut self, request: impl IntoRequest<ReqShowClearUnreadUi>, ) -> Result<Response<RspShowClearUnreadUi>, Status>
Sourcepub async fn single_unread(
&mut self,
request: impl IntoRequest<ReqSingleUnread>,
) -> Result<Response<RspSingleUnread>, Status>
pub async fn single_unread( &mut self, request: impl IntoRequest<ReqSingleUnread>, ) -> Result<Response<RspSingleUnread>, Status>
Sourcepub async fn specific_single_unread(
&mut self,
request: impl IntoRequest<ReqSpecificSingleUnread>,
) -> Result<Response<RspSpecificSingleUnread>, Status>
pub async fn specific_single_unread( &mut self, request: impl IntoRequest<ReqSpecificSingleUnread>, ) -> Result<Response<RspSpecificSingleUnread>, Status>
Sourcepub async fn sync_ack(
&mut self,
request: impl IntoRequest<ReqSyncAck>,
) -> Result<Response<RspSyncAck>, Status>
pub async fn sync_ack( &mut self, request: impl IntoRequest<ReqSyncAck>, ) -> Result<Response<RspSyncAck>, Status>
Sourcepub async fn sync_fetch_session_msgs(
&mut self,
request: impl IntoRequest<ReqSessionMsg>,
) -> Result<Response<RspSessionMsg>, Status>
pub async fn sync_fetch_session_msgs( &mut self, request: impl IntoRequest<ReqSessionMsg>, ) -> Result<Response<RspSessionMsg>, Status>
Sourcepub async fn sync_relation(
&mut self,
request: impl IntoRequest<ReqRelationSync>,
) -> Result<Response<RspRelationSync>, Status>
pub async fn sync_relation( &mut self, request: impl IntoRequest<ReqRelationSync>, ) -> Result<Response<RspRelationSync>, Status>
Sourcepub async fn update_ack(
&mut self,
request: impl IntoRequest<ReqUpdateAck>,
) -> Result<Response<DummyRsp>, Status>
pub async fn update_ack( &mut self, request: impl IntoRequest<ReqUpdateAck>, ) -> Result<Response<DummyRsp>, Status>
Sourcepub async fn update_intercept(
&mut self,
request: impl IntoRequest<ReqUpdateIntercept>,
) -> Result<Response<DummyRsp>, Status>
pub async fn update_intercept( &mut self, request: impl IntoRequest<ReqUpdateIntercept>, ) -> Result<Response<DummyRsp>, Status>
Sourcepub async fn update_total_unread(
&mut self,
request: impl IntoRequest<ReqUpdateTotalUnread>,
) -> Result<Response<RspUpdateTotalUnread>, Status>
pub async fn update_total_unread( &mut self, request: impl IntoRequest<ReqUpdateTotalUnread>, ) -> Result<Response<RspUpdateTotalUnread>, Status>
Sourcepub async fn update_unflw_read(
&mut self,
request: impl IntoRequest<DummyReq>,
) -> Result<Response<DummyRsp>, Status>
pub async fn update_unflw_read( &mut self, request: impl IntoRequest<DummyReq>, ) -> Result<Response<DummyRsp>, Status>
Sourcepub async fn update_user_cosmo_state(
&mut self,
request: impl IntoRequest<UpdateUserCosmoStateReq>,
) -> Result<Response<UpdateUserCosmoStateRsp>, Status>
pub async fn update_user_cosmo_state( &mut self, request: impl IntoRequest<UpdateUserCosmoStateReq>, ) -> Result<Response<UpdateUserCosmoStateRsp>, Status>
Trait Implementations§
Source§impl<T: Clone> Clone for ImInterfaceClient<T>
impl<T: Clone> Clone for ImInterfaceClient<T>
Source§fn clone(&self) -> ImInterfaceClient<T>
fn clone(&self) -> ImInterfaceClient<T>
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl<T> !Freeze for ImInterfaceClient<T>
impl<T> RefUnwindSafe for ImInterfaceClient<T>where
T: RefUnwindSafe,
impl<T> Send for ImInterfaceClient<T>where
T: Send,
impl<T> Sync for ImInterfaceClient<T>where
T: Sync,
impl<T> Unpin for ImInterfaceClient<T>where
T: Unpin,
impl<T> UnwindSafe for ImInterfaceClient<T>where
T: UnwindSafe,
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request