| … | … | ||
|---|---|---|---|
| 4 | use Coro; | 4 | use Coro; |
| 5 | use Coro::Channel; | 5 | use Coro::Channel; |
| 6 | 6 | ||
| 7 | my $q = new Coro::Channel 1; | 7 | my $q = new Coro::Channel 1; |
| 8 | 8 | ||
| 9 | sub producer : Coro { | 9 | async { # producer |
| 10 | for (1..9) { | 10 | for (1..9) { |
| 11 | print "ok ", $_*2, "\n"; | 11 | print "ok ", $_*2, "\n"; |
| 12 | $q->put($_); | 12 | $q->put($_); |
| 13 | } | 13 | } |
| 14 | } | 14 | }; |
| 15 | 15 | ||
| 16 | print "ok 1\n"; | 16 | print "ok 1\n"; |
| 17 | cede; | 17 | cede; |
| 18 | 18 | ||
| 19 | for (11..19) { | 19 | for (11..19) { |
| – | Removed lines |
| + | Added lines |
| < | Changed lines |
| > | Changed lines |