json_stream

json_splitter(buffer)[源代码]

尝试从缓冲区中解析一个 JSON 对象。如果至少有一个对象,则返回该对象和缓冲区的其余部分,否则返回 None。

json_stream(stream)[源代码]

给定一个文本流,返回一个 JSON 对象流。此函数处理缓冲不一致的流(有些条目可能以换行符分隔,而另一些则不然)。

line_splitter(buffer, separator='\n')[源代码]
split_buffer(stream, splitter=None, decoder=<function <lambda>>)[源代码]

给定一个生成字符串和分隔符函数的生成器,连接所有输入,按分隔符分割并生成每个块。与 string.split() 不同,每个块都包含尾随分隔符,但如果输入末尾没有找到分隔符,则最后一个块除外。

stream_as_text(stream)[源代码]

给定一个字节流或文本流,如果流中的任何项是字节,则将其转换为文本。一旦我们返回文本流而不是字节流,就可以删除此函数。