Async HTTP "polling"

polly

#!/usr/bin/env raku

use v6;

use Manifesto;
use Cro::HTTP::Client;


my $manifesto = Manifesto.new;

$manifesto.add-promise: Cro::HTTP::Client.get('http://localhost:3333/');

my $supply = supply {
    whenever $manifesto -> $thing {
        emit $thing;
    }
    whenever $manifesto.empty {
        $manifesto.add-promise: Cro::HTTP::Client.get('http://localhost:3333/');
    }
}

react {
    whenever $supply -> $response {
        say await $response.body;
    }
}