Skip to content
Permalink
Browse files

fix(router): respect num_part when set

  • Loading branch information...
hanxiao committed Aug 27, 2019
1 parent 87e4bcf commit d02cd7572338165fad697eb1cd02b47731b9e837
Showing with 1 addition and 1 deletion.
  1. +1 −1 gnes/service/router.py
@@ -31,7 +31,7 @@ def post_init(self):
self._pending = defaultdict(list) # type: Dict[str, List]

def _is_msg_complete(self, msg: 'gnes_pb2.Message', num_req: int) -> bool:
return (num_req == msg.envelope.num_part[-1]) or \
return (self.args.num_part is None and num_req == msg.envelope.num_part[-1]) or \
(num_req == self.args.num_part)

@handler.register(NotImplementedError)

0 comments on commit d02cd75

Please sign in to comment.
You can’t perform that action at this time.