Cro::MQTT spoiler

gistfile1.txt

use Cro::MQTT;

my $subscriptions = subscriptions {
    subscribe 'hello-world', {
        consume -> $m { say "GOT HELLO WORLD ", $m.message.decode }
    }
    subscribe 'another-world', {
        consume -> $m { say "GOT ANOTHER WORLD ", $m.message.decode }
    }
}

my $service = Cro::MQTT.new(
    port => 1883,
    :$subscriptions
);

$service.start;

react {
    whenever signal(SIGINT) {
        $service.stop;
        done;
    }
}