()
| 685 | |
| 686 | @gen.coroutine |
| 687 | def produce(): |
| 688 | remaining = nbytes |
| 689 | while remaining > 0: |
| 690 | size = r.randint(1, min(1000, remaining)) |
| 691 | data = os.urandom(size) |
| 692 | produce_hash.update(data) |
| 693 | yield ws.write(data) |
| 694 | remaining -= size |
| 695 | assert remaining == 0 |
| 696 | |
| 697 | @gen.coroutine |
| 698 | def consume(): |