Type Members

1.  trait MqttControl extends AnyRef

   Represents an application view of a connection to an MQTT broker as used by a stage

2.  trait MqttMessageWithAck extends AnyRef

   Scala API

   Scala API

   MQTT Message and a handle to acknowledge message reception to MQTT.

3.  trait PublishWithPassThrough[+T] extends AnyRef

   Represents a message to be published to MQTT along with a "pass-through" element to be emitted after successfully publishing.

   Represents a message to be published to MQTT along with a "pass-through" element to be emitted after successfully publishing.

   Not for user extension

   Annotations

   @DoNotInherit()