Failing unit test (as it should) for replyStream since it fails to thread the subscriptions through the calls
Failing unit test (as it should) for replyStream since it fails to thread the subscriptions through the calls

atilaneves/mqtt_hs,atilaneves/mqtt_hs