如何将可迭代对象转换为流?

如何将可迭代对象转换为流?,第1张

如何将可迭代对象转换为流?

这是我的流式迭代器,它是urllib3的实验分支,它支持通过可迭代的流式分块请求

class IterStreamer(object):    """    File-like streaming iterator.    """    def __init__(self, generator):        self.generator = generator        self.iterator = iter(generator)        self.leftover = ''    def __len__(self):        return self.generator.__len__()    def __iter__(self):        return self.iterator    def next(self):        return self.iterator.next()    def read(self, size):        data = self.leftover        count = len(self.leftover)        if count < size: try:     while count < size:         chunk = self.next()         data += chunk         count += len(chunk) except StopIteration:     pass        self.leftover = data[size:]        return data[:size]

带有上下文的源代码:https : //github.com/shazow/urllib3/blob/filepost-
stream/urllib3/filepost.py#L23

相关单元测试:https : //github.com/shazow/urllib3/blob/filepost-
stream/test/test_filepost.py#L9

遗憾的是,此代码尚未进入稳定分支,因为无法支持无大小的分块请求,但它应该为您要执行的 *** 作奠定良好的基础。有关显示如何使用它的示例,请参见源链接。



欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/zaji/5646620.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-12-16
下一篇 2022-12-16

发表评论

登录后才能评论

评论列表(0条)

保存