HiveMQ

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> ?