Show More
@@ -531,6 +531,9 b' class bufferingcommandresponseemitter(ob' | |||
|
531 | 531 | # * If a chunk causes us to go over our buffering limit, we flush |
|
532 | 532 | # and then buffer the new chunk. |
|
533 | 533 | |
|
534 | if not data: | |
|
535 | return | |
|
536 | ||
|
534 | 537 | if len(data) > self._maxsize: |
|
535 | 538 | for frame in self._flush(): |
|
536 | 539 | yield frame |
@@ -573,6 +576,9 b' class bufferingcommandresponseemitter(ob' | |||
|
573 | 576 | self._chunks[:] = [] |
|
574 | 577 | self._chunkssize = 0 |
|
575 | 578 | |
|
579 | if not payload: | |
|
580 | return | |
|
581 | ||
|
576 | 582 | yield self._stream.makeframe( |
|
577 | 583 | self._requestid, |
|
578 | 584 | typeid=FRAME_TYPE_COMMAND_RESPONSE, |
@@ -394,7 +394,6 b' class ServerReactorTests(unittest.TestCa' | |||
|
394 | 394 | b'1 2 0 command-response continuation Y\x80d', |
|
395 | 395 | b'1 2 0 command-response continuation %s' % first, |
|
396 | 396 | b'1 2 0 command-response continuation %s' % second, |
|
397 | b'1 2 0 command-response continuation ', | |
|
398 | 397 | b'1 2 0 command-response eos ' |
|
399 | 398 | ]) |
|
400 | 399 |
General Comments 0
You need to be logged in to leave comments.
Login now