ping-pong-end-emit.p6

use v6.d;

my Supplier $pinger .= new;
my Supplier $ponger .= new;

react {
    say 'Beginning ping/pong...';
    whenever $pinger.Supply.throttle: 1, 1 {
        .say;
        $ponger.emit: 'pong';
    }
    whenever $ponger.Supply.throttle: 1, 1 {
        .say;
        $pinger.emit: 'ping';
    }
    whenever Promise.in(10) {
        exit 0;
    }
    $pinger.emit: 'ping';
}

ping-pong-supplier-preserving.p6

use v6.d;

my Supplier::Preserving $pinger .= new;
my Supplier::Preserving $ponger .= new;

react {
    ENTER {
        say 'Beginning ping/pong...';
        $pinger.emit: 'ping';
    }
    whenever $pinger.Supply.throttle: 1, 1 {
        .say;
        $ponger.emit: 'pong';
    }
    whenever $ponger.Supply.throttle: 1, 1 {
        .say;
        $pinger.emit: 'ping';
    }
    whenever Promise.in(10) {
        exit 0;
    }
}