Commit cf984cee authored by Raymond Hettinger's avatar Raymond Hettinger

Generalize the itertools.tee() recipe.

parent 0654ccd1
...@@ -130,7 +130,7 @@ loops that truncate the stream. ...@@ -130,7 +130,7 @@ loops that truncate the stream.
return return
indices = list(range(r)) indices = list(range(r))
yield tuple(pool[i] for i in indices) yield tuple(pool[i] for i in indices)
while 1: while True:
for i in reversed(range(r)): for i in reversed(range(r)):
if indices[i] != i + n - r: if indices[i] != i + n - r:
break break
...@@ -178,7 +178,7 @@ loops that truncate the stream. ...@@ -178,7 +178,7 @@ loops that truncate the stream.
return return
indices = [0] * r indices = [0] * r
yield tuple(pool[i] for i in indices) yield tuple(pool[i] for i in indices)
while 1: while True:
for i in reversed(range(r)): for i in reversed(range(r)):
if indices[i] != n - 1: if indices[i] != n - 1:
break break
...@@ -501,28 +501,28 @@ loops that truncate the stream. ...@@ -501,28 +501,28 @@ loops that truncate the stream.
.. function:: tee(iterable[, n=2]) .. function:: tee(iterable[, n=2])
Return *n* independent iterators from a single iterable. The case where ``n==2`` Return *n* independent iterators from a single iterable. Equivalent to::
is equivalent to::
def tee(iterable): def tee(iterable, n=2):
def gen(next, data={}):
for i in count():
if i in data:
yield data.pop(i)
else:
data[i] = next()
yield data[i]
it = iter(iterable) it = iter(iterable)
return (gen(it.__next__), gen(it.__next__)) deques = [collections.deque() for i in range(n)]
def gen(mydeque):
Note, once :func:`tee` has made a split, the original *iterable* should not be while True:
used anywhere else; otherwise, the *iterable* could get advanced without the tee if not mydeque: # when the local deque is empty
objects being informed. newval = next(it) # fetch a new value and
for d in deques: # load it to all the deques
Note, this member of the toolkit may require significant auxiliary storage d.append(newval)
(depending on how much temporary data needs to be stored). In general, if one yield mydeque.popleft()
iterator is going to use most or all of the data before the other iterator, it return tuple(gen(d) for d in deques)
is faster to use :func:`list` instead of :func:`tee`.
Once :func:`tee` has made a split, the original *iterable* should not be
used anywhere else; otherwise, the *iterable* could get advanced without
the tee objects being informed.
This itertool may require significant auxiliary storage (depending on how
much temporary data needs to be stored). In general, if one iterator uses
most or all of the data before another iterator starts, it is faster to use
:func:`list` instead of :func:`tee`.
.. function:: zip_longest(*iterables[, fillvalue]) .. function:: zip_longest(*iterables[, fillvalue])
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment