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) -> Self

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

Trait Implementations

impl<P: Protocol, T: Serialize> IntoOutboundMessage<P> for TypedMessage<T>

fn into_outbound( self, ready: &P::Ready, codec: &dyn EnvelopeCodec, ) -> ClientResult<OutboundMessage>

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