小编Ken*_* Pu的帖子

关于Python Twisted框架,有人可以向我解释如何将非常大的数据字符串异步写入消费者,比如protocol.transport对象吗？

我想我缺少的是一个write(data_chunk)返回a 的函数Deferred.这就是我想做的事情:

data_block = get_lots_and_lots_data()
CHUNK_SIZE = 1024 # write 1-K at a time.
def write_chunk(data, i):
  d = transport.deferredWrite(data[i:i+CHUNK_SIZE])
  d.addCallback(write_chunk, data, i+1)
write_chunk(data, 0)

但是,经过一天在Twisted API/Documentation中闲逛之后,我似乎无法找到类似deferredWrite等价物的东西.我错过了什么？