Struct MqttClient 

pub struct MqttClient { /* private fields */ }

A component that represents an MQTT client

Methods from Deref<Target = Client>

pub fn publish<S, V>( &self, topic: S, qos: QoS, retain: bool, payload: V, ) -> Result<(), ClientError>

where S: Into<String>, V: Into<Vec<u8>>,

Sends a MQTT Publish to the EventLoop

pub fn try_publish<S, V>( &self, topic: S, qos: QoS, retain: bool, payload: V, ) -> Result<(), ClientError>

where S: Into<String>, V: Into<Vec<u8>>,

pub fn ack(&self, publish: &Publish) -> Result<(), ClientError>

Sends a MQTT PubAck to the EventLoop. Only needed in if manual_acks flag is set.

pub fn try_ack(&self, publish: &Publish) -> Result<(), ClientError>

Sends a MQTT PubAck to the EventLoop. Only needed in if manual_acks flag is set.

pub fn subscribe<S>(&self, topic: S, qos: QoS) -> Result<(), ClientError>

where S: Into<String>,

Sends a MQTT Subscribe to the EventLoop

pub fn try_subscribe<S>(&self, topic: S, qos: QoS) -> Result<(), ClientError>

where S: Into<String>,

Sends a MQTT Subscribe to the EventLoop

pub fn subscribe_many<T>(&self, topics: T) -> Result<(), ClientError>

where T: IntoIterator<Item = SubscribeFilter>,

Sends a MQTT Subscribe for multiple topics to the EventLoop

pub fn try_subscribe_many<T>(&self, topics: T) -> Result<(), ClientError>

where T: IntoIterator<Item = SubscribeFilter>,

pub fn unsubscribe<S>(&self, topic: S) -> Result<(), ClientError>

where S: Into<String>,

Sends a MQTT Unsubscribe to the EventLoop

pub fn try_unsubscribe<S>(&self, topic: S) -> Result<(), ClientError>

where S: Into<String>,

Sends a MQTT Unsubscribe to the EventLoop

pub fn disconnect(&self) -> Result<(), ClientError>

Sends a MQTT disconnect to the EventLoop

pub fn try_disconnect(&self) -> Result<(), ClientError>

Sends a MQTT disconnect to the EventLoop

Trait Implementations

impl Clone for MqttClient

fn clone(&self) -> MqttClient

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Component for MqttClient

where Self: Send + Sync + 'static,

const STORAGE_TYPE: StorageType = bevy_ecs::component::StorageType::Table

A constant indicating the storage type used for this component.

type Mutability = Mutable

A marker type to assist Bevy with determining if this component is mutable, or immutable. Mutable components will have Component<Mutability = Mutable>, while immutable components will instead have Component<Mutability = Immutable>.

fn register_required_components( _requiree: ComponentId, required_components: &mut RequiredComponentsRegistrator<'_, '_>, )

Registers required components.

fn clone_behavior() -> ComponentCloneBehavior

Called when registering this component, allowing to override clone function (or disable cloning altogether) for this component.

fn on_add() -> Option<for<'w> fn(DeferredWorld<'w>, HookContext)>

Gets the on_add ComponentHook for this Component if one is defined.

fn on_insert() -> Option<for<'w> fn(DeferredWorld<'w>, HookContext)>

Gets the on_insert ComponentHook for this Component if one is defined.

fn on_replace() -> Option<for<'w> fn(DeferredWorld<'w>, HookContext)>

Gets the on_replace ComponentHook for this Component if one is defined.

fn on_remove() -> Option<for<'w> fn(DeferredWorld<'w>, HookContext)>

Gets the on_remove ComponentHook for this Component if one is defined.

fn on_despawn() -> Option<for<'w> fn(DeferredWorld<'w>, HookContext)>

Gets the on_despawn ComponentHook for this Component if one is defined.

fn map_entities<E>(_this: &mut Self, _mapper: &mut E)

where E: EntityMapper,

Maps the entities on this component using the given EntityMapper. This is used to remap entities in contexts like scenes and entity cloning. When deriving Component, this is populated by annotating fields containing entities with #[entities]

impl Deref for MqttClient

type Target = Client

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl DerefMut for MqttClient

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.