Statically Building FluxWithSingle<Mqtt5Publish, Mqtt5SubAck>

I’m writing tests for my application and need to Mock out the stream of messages my subscriber will be receiving.
How do I statically build a dummy FluxWithSingle<Mqtt5Publishm Mqtt5SubAck> ?

Hi Jordan,

For testing applications our suggested way is to use HiveMQ Swarm – HiveMQ Swarm provides the distributed simulation environment to successfully test millions of MQTT clients, millions of MQTT messages and hundreds of thousands MQTT topic names.

For a deep dive with working examples, please check out the HiveMQ Swam Documentation.

Kind regards,
Dasha from HiveMQ Team