messagesForTopic

Returns a Flow of messages filtered to a specific topic.

Performs an exact match on MqttMessage.topic. For wildcard filtering, use messagesMatching instead.

Example

client.messagesForTopic("sensors/temperature").collect { msg ->
    println("Temp: ${msg.payloadAsString()}")
}