/usr/share/pyshared/messaging/mms/iterator.py is in python-messaging 0.5.11+debian-1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 | # This library is free software.
#
# It was originally distributed under the terms of the GNU Lesser
# General Public License Version 2.
#
# python-messaging opts to apply the terms of the ordinary GNU
# General Public License v2, as permitted by section 3 of the LGPL
# v2.1. This re-licensing allows the entirety of python-messaging to
# be distributed according to the terms of GPL-2.
#
# See the COPYING file included in this archive
#
# The docstrings in this module contain epytext markup; API documentation
# may be created by processing this file with epydoc: http://epydoc.sf.net
"""Iterator with "value preview" capability."""
class PreviewIterator(object):
"""An ``iter`` wrapper class providing a "previewable" iterator.
This "preview" functionality allows the iterator to return successive
values from its ``iterable`` object, without actually mvoving forward
itself. This is very usefuly if the next item(s) in an iterator must
be used for something, after which the iterator should "undo" those
read operations, so that they can be read again by another function.
From the user point of view, this class supersedes the builtin iter()
function: like iter(), it is called as PreviewIter(iterable).
"""
def __init__(self, data):
self._it = iter(data)
self._cached_values = []
self._preview_pos = 0
def __iter__(self):
return self
def next(self):
self.reset_preview()
if len(self._cached_values) > 0:
return self._cached_values.pop(0)
else:
return self._it.next()
def preview(self):
"""
Return the next item in the ``iteratable`` object
But it does not modify the actual iterator (i.e. do not
intefere with :func:`next`.
Successive calls to :func:`preview` will return successive values from
the ``iterable`` object, exactly in the same way :func:`next` does.
However, :func:`preview` will always return the next item from
``iterable`` after the item returned by the previous :func:`preview`
or :func:`next` call, whichever was called the most recently.
To force the "preview() iterator" to synchronize with the "next()
iterator" (without calling :func:`next`), use :func:`reset_preview`.
"""
if self._preview_pos < len(self._cached_values):
value = self._cached_values[self._preview_pos]
else:
value = self._it.next()
self._cached_values.append(value)
self._preview_pos += 1
return value
def reset_preview(self):
self._preview_pos = 0
|