Show More
@@ -458,7 +458,10 b' class clienthandler(object):' | |||||
458 | self._redirects.append((requestid, res)) |
|
458 | self._redirects.append((requestid, res)) | |
459 |
|
459 | |||
460 | def _processredirect(self, rid, res): |
|
460 | def _processredirect(self, rid, res): | |
461 |
"""Called to continue processing a response from a redirect. |
|
461 | """Called to continue processing a response from a redirect. | |
|
462 | ||||
|
463 | Returns a bool indicating if the redirect is still serviceable. | |||
|
464 | """ | |||
462 | response = self._responses[rid] |
|
465 | response = self._responses[rid] | |
463 |
|
466 | |||
464 | try: |
|
467 | try: | |
@@ -470,7 +473,7 b' class clienthandler(object):' | |||||
470 | response._oninputcomplete() |
|
473 | response._oninputcomplete() | |
471 |
|
474 | |||
472 | if rid not in self._futures: |
|
475 | if rid not in self._futures: | |
473 | return |
|
476 | return bool(data) | |
474 |
|
477 | |||
475 | if response.command not in COMMAND_DECODERS: |
|
478 | if response.command not in COMMAND_DECODERS: | |
476 | self._futures[rid].set_result(response.objects()) |
|
479 | self._futures[rid].set_result(response.objects()) |
General Comments 0
You need to be logged in to leave comments.
Login now