Merge pull request #1 from seiriosPlus/tangw/simple_pipe_reader

fix pipe_reader unimport packages
release/0.11.0
武毅 7 years ago committed by GitHub
commit cd36531537
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

@ -14,13 +14,16 @@
__all__ = [ __all__ = [
'map_readers', 'buffered', 'compose', 'chain', 'shuffle', '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 itertools
import random import random
from Queue import Queue import zlib
from threading import Thread
def map_readers(func, *readers): def map_readers(func, *readers):

Loading…
Cancel
Save