提交 bf360c77 编写于 作者: T tangwei12

fix pipe_reader unimport packages

上级 aeeb77de
......@@ -14,13 +14,16 @@
__all__ = [
'map_readers', 'buffered', 'compose', 'chain', 'shuffle',
'ComposeNotAligned', 'firstn', 'xmap_readers'
'ComposeNotAligned', 'firstn', 'xmap_readers', 'pipe_reader'
]
from threading import Thread
import subprocess
from Queue import Queue
import itertools
import random
from Queue import Queue
from threading import Thread
import zlib
def map_readers(func, *readers):
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册