Struct TypedMessage 

pub struct TypedMessage<T> {
    pub message_type: String,
    pub payload: T,
}

Native payload paired with an explicit wire name; this is not schema proof.

Fields

message_type: String

Application wire name.

payload: T

Native serializable value, often a borrowed prepared request.

Implementations

impl<T> TypedMessage<T>

pub fn new(message_type: impl AsRef<str>, payload: T) -> TypedMessage<T>

Pair a native payload with a wire name without performing I/O.

Trait Implementations

impl<P, T> IntoOutboundMessage<P> for TypedMessage<T>

where P: Protocol, T: Serialize,

fn into_outbound( self, ready: &<P as Protocol>::Ready, codec: &(dyn EnvelopeCodec + 'static), ) -> Result<OutboundMessage, ClientError>

Validate before admission and encode only the layer supplied by the caller.