Struct ServerTaskVariant 

pub struct ServerTaskVariant<T, M, E>
where
    T: Send + 'static,
    M: Send + 'static,
    E: RpcErrCodec,
{
    pub seq: u64,
    pub action: RpcActionOwned,
    pub msg: M,
    pub blob: Option<Buffer>,
    pub res: Option<Result<(), E>>,
    pub noti: Option<RespNoti<T>>,
}

A container that impl ServerTaskResp to show an example, presuming you have a different types to represent Request and Response. You can write your customize version.

Fields

seq: u64

action: RpcActionOwned

msg: M

blob: Option<Buffer>

res: Option<Result<(), E>>

noti: Option<RespNoti<T>>

Trait Implementations

impl<T, M, E> Debug for ServerTaskVariant<T, M, E>

where T: Send + 'static, M: Debug + Send + 'static, E: RpcErrCodec + Display,

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

Formats the value using the given formatter.

impl<T, M, E> ServerTaskAction for ServerTaskVariant<T, M, E>

where T: Send + 'static, M: Send + 'static, E: RpcErrCodec,

fn get_action<'a>(&'a self) -> RpcAction<'a>

impl<T, M, E> ServerTaskDecode<T> for ServerTaskVariant<T, M, E>

where T: Send + 'static, M: for<'b> Deserialize<'b> + Send + 'static, E: RpcErrCodec,

fn decode_req<'a, C: Codec>( codec: &'a C, action: RpcAction<'a>, seq: u64, msg: &'a [u8], blob: Option<Buffer>, noti: RespNoti<T>, ) -> Result<Self, ()>

impl<T, M, E> ServerTaskDone<T, E> for ServerTaskVariant<T, M, E>

where T: Send + 'static, M: Send + 'static, E: RpcErrCodec,

fn _set_result(&mut self, res: Result<(), E>) -> RespNoti<T>

Should implement for enum delegation, not intended for user call

fn set_result(self, res: Result<(), E>)

where T: From<Self>,

For users, set the result in the task and send it back

impl<T, M, E> ServerTaskEncode for ServerTaskVariant<T, M, E>

where T: Send + 'static, M: Serialize + Send + 'static, E: RpcErrCodec,

fn encode_resp<'a, 'b, C: Codec>( &'a mut self, codec: &'b C, buf: &'b mut Vec<u8>, ) -> (u64, Result<(usize, Option<&'a [u8]>), EncodedErr>)