DeferredRequestStream

类私有上下文源码

stream = DeferredRequestStream(
    info: CachedFileInfo,
    data: CachedRequest
)
with stream as resp:
    resp: ProtocolResponse

从某个预设请求、所对应的响应、传递而来的延迟数据流。

进入该类上下文时，会向远端资源建立连接。在上下文的范围内，可以读取或传递从远端来的数据流。

参数

参数	类型	必选	说明
info	CachedFileInfo		从缓存中获取的数据信息。
data	CachedRequest		从缓存中加载的请求配置。

方法

close

stream.close()

关闭所有仍存在的连接。

备注

退出上下文时，会自动调用该方法。

close

data: Iterator[bytes] = stream.provide(chunk_size: int = 1024 * 1024)

从该延迟请求流之中、生成数据供应器。

须知该方法设计成、在上下文范围之外使用。使用该方法时，该方法会在流提供器的范围内维护上下文。换言之，在用尽该方法返回的数据后，上下文会自动关闭。

注意

所返回的data会令stream上下文进入“打开”状态。需要弃置数据迭代器时，建议显式调用close()方法。

输入

参数	类型	必选	说明
chunk_size	int		用来传递数据的块尺寸。

输出

参数	类型	说明
data	Iterator[bytes]	该方法生成的数据流。