equal
deleted
inserted
replaced
484 outstream = framing.outputstream(2) |
484 outstream = framing.outputstream(2) |
485 outstream.setencoder(globalui, b'zlib') |
485 outstream.setencoder(globalui, b'zlib') |
486 |
486 |
487 response1 = b''.join( |
487 response1 = b''.join( |
488 cborutil.streamencode( |
488 cborutil.streamencode( |
489 {b'status': b'ok', b'extra': b'response1' * 10,} |
489 { |
|
490 b'status': b'ok', |
|
491 b'extra': b'response1' * 10, |
|
492 } |
490 ) |
493 ) |
491 ) |
494 ) |
492 |
495 |
493 response2 = b''.join( |
496 response2 = b''.join( |
494 cborutil.streamencode( |
497 cborutil.streamencode( |
495 {b'status': b'error', b'extra': b'response2' * 10,} |
498 { |
|
499 b'status': b'error', |
|
500 b'extra': b'response2' * 10, |
|
501 } |
496 ) |
502 ) |
497 ) |
503 ) |
498 |
504 |
499 action, meta = sendframe( |
505 action, meta = sendframe( |
500 reactor, |
506 reactor, |
676 outstream = framing.outputstream(2) |
682 outstream = framing.outputstream(2) |
677 outstream.setencoder(globalui, b'zstd-8mb') |
683 outstream.setencoder(globalui, b'zstd-8mb') |
678 |
684 |
679 response1 = b''.join( |
685 response1 = b''.join( |
680 cborutil.streamencode( |
686 cborutil.streamencode( |
681 {b'status': b'ok', b'extra': b'response1' * 10,} |
687 { |
|
688 b'status': b'ok', |
|
689 b'extra': b'response1' * 10, |
|
690 } |
682 ) |
691 ) |
683 ) |
692 ) |
684 |
693 |
685 response2 = b''.join( |
694 response2 = b''.join( |
686 cborutil.streamencode( |
695 cborutil.streamencode( |
687 {b'status': b'error', b'extra': b'response2' * 10,} |
696 { |
|
697 b'status': b'error', |
|
698 b'extra': b'response2' * 10, |
|
699 } |
688 ) |
700 ) |
689 ) |
701 ) |
690 |
702 |
691 action, meta = sendframe( |
703 action, meta = sendframe( |
692 reactor, |
704 reactor, |