equal
deleted
inserted
replaced
349 def get_cached_bundle_inline(self, path): |
349 def get_cached_bundle_inline(self, path): |
350 stream = self._callstream(b"get_cached_bundle_inline", path=path) |
350 stream = self._callstream(b"get_cached_bundle_inline", path=path) |
351 length = util.uvarintdecodestream(stream) |
351 length = util.uvarintdecodestream(stream) |
352 |
352 |
353 # SSH streams will block if reading more than length |
353 # SSH streams will block if reading more than length |
354 for chunk in util.filechunkiter(stream, limit=length): |
354 yield from util.filechunkiter(stream, limit=length) |
355 yield chunk |
|
356 |
355 |
357 self._finish_inline_clone_bundle(stream) |
356 self._finish_inline_clone_bundle(stream) |
358 |
357 |
359 @batchable |
358 @batchable |
360 def lookup(self, key): |
359 def lookup(self, key): |