Type Definition svc_agent::mqtt::IncomingRequest

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

Methods

impl<T> IncomingRequest<T>

pub fn to_response<R>(
    &self,
    data: R,
    status: ResponseStatus,
    timing: OutgoingShortTermTimingProperties,
    api_version: &str
) -> OutgoingResponse<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),
);