Struct IncomingMessageContent 

pub struct IncomingMessageContent<T, P>
where
    P: Addressable + Serialize,
{ /* private fields */ }

Implementations

impl<String: Deref<Target = str>> IncomingMessageContent<String, IncomingEventProperties>

pub fn convert_payload<T>(message: &IncomingEvent<String>) -> Result<T, Error>

where T: DeserializeOwned,

pub fn convert<T>( message: IncomingEvent<String>, ) -> Result<IncomingEvent<T>, Error>

where T: DeserializeOwned,

impl<T> IncomingMessageContent<T, IncomingRequestProperties>

pub fn to_response<R>( &self, data: R, status: ResponseStatus, timing: OutgoingShortTermTimingProperties, api_version: &str, ) -> OutgoingMessage<R>

where R: Serialize,

Builds OutgoingResponse based on the IncomingRequest.

Use it to response on a request.

Arguments

• data – serializable response payload.
• status – response status.
• timing – outgoing response’s short term timing properties.

Example

let response = request.to_response(
    json!({ "foo": "bar" }),
    ResponseStatus::OK,
    OutgoingShortTermTimingProperties::until_now(start_timestamp),
);

impl<String: Deref<Target = str>> IncomingMessageContent<String, IncomingRequestProperties>

pub fn convert_payload<T>(message: &IncomingRequest<String>) -> Result<T, Error>

where T: DeserializeOwned,

pub fn convert<T>( message: IncomingRequest<String>, ) -> Result<IncomingRequest<T>, Error>

where T: DeserializeOwned,

impl<String: Deref<Target = str>> IncomingMessageContent<String, IncomingResponseProperties>

pub fn convert_payload<T>( message: &IncomingResponse<String>, ) -> Result<T, Error>

where T: DeserializeOwned,

pub fn convert<T>( message: IncomingResponse<String>, ) -> Result<IncomingResponse<T>, Error>

where T: DeserializeOwned,

impl<T, P> IncomingMessageContent<T, P>

where P: Addressable + Serialize,

pub fn new(payload: T, properties: P) -> Self

pub fn payload(&self) -> &T

pub fn extract_payload(self) -> T

pub fn properties(&self) -> &P

pub fn properties_mut(&mut self) -> &mut P

Trait Implementations

impl<T: Clone, P> Clone for IncomingMessageContent<T, P>

where P: Addressable + Serialize + Clone,

fn clone(&self) -> IncomingMessageContent<T, P>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug, P> Debug for IncomingMessageContent<T, P>

where P: Addressable + Serialize + Debug,

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

Formats the value using the given formatter.