[−][src]Type Definition svc_agent::mqtt::OutgoingEvent

type OutgoingEvent<T> = OutgoingMessage<T, OutgoingEventProperties>;

Methods

impl<T> OutgoingEvent<T> where
    T: Serialize, [src]

pub fn broadcast(
    payload: T,
    properties: OutgoingEventProperties,
    to_uri: &str
) -> Self[src]

Builds a broadcast event to publish.

Arguments

  • payload – any serializable value.
  • properties – properties of the outgoing event.
  • to_uri – broadcast resource path. See Destination for details.

Example

let short_term_timing = OutgoingShortTermTimingProperties::until_now(start_timestamp);

let message = OutgoingEvent::broadcast(
    json!({ "foo": "bar" }),
    request.to_event("message.create", short_term_timing),
    "rooms/123/events",
);

Trait Implementations

impl<T> IntoEnvelope for OutgoingEvent<T> where
    T: Serialize, [src]

impl<T: Serialize> Publishable for OutgoingEvent<T> where
    OutgoingEvent<T>: IntoEnvelope, [src]