Inheritance diagram for Tests.Adapters.TestMqttMediator:

Collaboration diagram for Tests.Adapters.TestMqttMediator:

Public Member Functions
	TestMqttMediator (Queue<(object sender, MqttApplicationMessage msg)> sentMessages)

override IEnumerable< ITarget< string, MqttApplicationMessage > >	GetChannelCopy (string key)

override bool	HasSubscribersOnTopic (string topic)

override int	TargetCountOnChannel (string key)

override void	Unsubscribe (ISubscription< string, MqttApplicationMessage > subscription)

override void	Subscribe (string msgChannel, ITarget< string, MqttApplicationMessage > target, out ISubscription subscription)

Public Member Functions inherited from IotDash.Services.Mqtt.MqttMediator
abstract bool	HasSubscribersOnTopic (string topic)

MqttApplicationMessage?	GetRetained (string topic)

override Task	Send (string channel, object sender, MqttApplicationMessage msg)

Task	Send (string topic, object sender, string content)

Public Member Functions inherited from IotDash.Domain.Mediator.AbstractMediator< string, MqttApplicationMessage >
virtual void	Subscribe (TChannelKey msgChannel, ITarget< TChannelKey, TMsg > target, out ISubscription subscription)

virtual void	Subscribe (TChannelKey msgChannel, ITarget< TChannelKey, TMsg > target, SubscriptionGuard guard)

abstract int	TargetCountOnChannel (TChannelKey key)

abstract IEnumerable< ITarget< TChannelKey, TMsg > >	GetChannelCopy (TChannelKey key)

abstract void	Unsubscribe (ISubscription< TChannelKey, TMsg > subscription)

abstract Task	Send (TChannelKey msgChannel, object sender, TMsg msg)

Protected Member Functions
override async Task	MqttSend (string channel, object sender, MqttApplicationMessage msg)

override void	SubscribeInternal (string msgChannel, ITarget< string, MqttApplicationMessage > target)

abstract Task	MqttSend (string channel, object sender, MqttApplicationMessage msg)

Protected Member Functions inherited from IotDash.Domain.Mediator.AbstractMediator< string, MqttApplicationMessage >
abstract void	SubscribeInternal (TChannelKey msgChannel, ITarget< TChannelKey, TMsg > target)

Properties
override int	TargetCount `[get]`

override IEnumerable< string >	Keys `[get]`

Properties inherited from IotDash.Domain.Mediator.AbstractMediator< string, MqttApplicationMessage >
abstract int	TargetCount `[get]`

abstract IEnumerable< TChannelKey >	Keys `[get]`

Member Function Documentation

◆ HasSubscribersOnTopic()

override bool Tests.Adapters.TestMqttMediator.HasSubscribersOnTopic ( string topic )

virtual

Check if there are any subscribers on given topic .

Parameters

topic The topic to check.

override async Task Tests.Adapters.TestMqttMediator.MqttSend	(	string	channel,
		object	sender,
		MqttApplicationMessage	msg
	)

inlineprotectedvirtual

The documentation for this class was generated from the following file: