Struct ya_service_bus::RpcStreamCall

pub struct RpcStreamCall<T: RpcStreamMessage> {
    pub caller: String,
    pub addr: String,
    pub body: T,
    pub reply: Sender<Result<T::Item, T::Error>>,
}

Fields

caller: String

addr: String

body: T

reply: Sender<Result<T::Item, T::Error>>

Trait Implementations

impl<T: Debug + RpcStreamMessage> Debug for RpcStreamCall<T> where
    T::Item: Debug,
    T::Error: Debug, 

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

Formats the value using the given formatter.

impl<T: RpcStreamMessage> Message for RpcStreamCall<T>

type Result = Result<(), Error>

The type of value that this message will resolved with if it is successful.