… | … | ||
---|---|---|---|
45 | $wr_ae->on_drain; | 45 | $wr_ae->on_drain; |
46 | print "ok " . $n++ . " - fourth write\n"; | 46 | print "ok " . $n++ . " - fourth write\n"; |
47 | 47 | ||
48 | }); | 48 | }); |
49 | 49 | ||
50 | $rd_ae->push_read (chunk => 1, sub { | 50 | $rd_ae->push_read (chunk => 5000, sub { |
51 | print "ok " . $n++ . " - second read chunk\n"; | 51 | print "ok " . $n++ . " - second read chunk\n"; |
52 | $cv->broadcast | 52 | $cv->broadcast |
53 | }); | 53 | }); |
54 | }); | 54 | }); |
55 | 55 |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |