Type Definition svc_agent::mqtt::IncomingRequest

pub 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,