Type Definition svc_agent::mqtt::IncomingRequest

type IncomingRequest<T> = IncomingMessageContent<T, IncomingRequestProperties>;

Implementations

impl<T> IncomingRequest<T>

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>> IncomingRequest<String>

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,