Documentation

sendStreamMQTT :: Store alpha => String -> MQTTConfig -> Metrics -> Stream alpha -> IO () Source #

runMQTTSub :: Store alpha => String -> MQTTConfig -> Metrics -> InChan (Event alpha) -> IO () Source #