public const string __doc__ = "Provides functions and classes for working with iterable objects.";

public static object tee(object iterable) {

return tee(iterable, 2);

}

public static object tee(object iterable, int n) {

if (n < 0) throw PythonOps.ValueError("n cannot be negative");

object[] res = new object[n];

if (!(iterable is TeeIterator)) {

IEnumerator iter = PythonOps.GetEnumerator(iterable);

PythonList dataList = new PythonList();

for (int i = 0; i < n; i++) {

res[i] = new TeeIterator(iter, dataList);

}

} else if (n != 0) {

// if you pass in a tee you get back the original tee

// and other iterators that share the same data.

TeeIterator ti = iterable as TeeIterator;

res[0] = ti;

for (int i = 1; i < n; i++) {

res[1] = new TeeIterator(ti._iter, ti._data);

}

}

return PythonTuple.MakeTuple(res);

}

/// <summary>

/// Base class used for iterator wrappers.

/// </summary>

[PythonType, PythonHidden]

public class IterBase : IEnumerator {

private IEnumerator _inner;

internal IEnumerator InnerEnumerator {

set { _inner = value; }

}

#region IEnumerator Members

object IEnumerator.Current {

get { return _inner.Current; }

}

bool IEnumerator.MoveNext() {

return _inner.MoveNext();

}

void IEnumerator.Reset() {

_inner.Reset();

}

public object __iter__() {

return this;

}

#endregion

}

[PythonType]

public class accumulate : IterBase {

private static readonly object Undefined = new object();

private readonly IEnumerator iterable;

private readonly object func;

private object total;

public accumulate(CodeContext/*!*/ context, object iterable, object func = null) {

this.iterable = PythonOps.GetEnumerator(iterable);

this.func = func;

total = Undefined;

InnerEnumerator = Accumulator(context, this.iterable, func);

}

public PythonTuple __reduce__() {

return PythonTuple.MakeTuple(

DynamicHelpers.GetPythonType(this),

PythonTuple.MakeTuple(iterable, func),

total == Undefined ? null : total

);

}

public void __setstate__(object state) {

total = state;

}

private IEnumerator<object> Accumulator(CodeContext/*!*/ context, IEnumerator iterable, object function) {

if (!MoveNextHelper(iterable)) {

yield break;

}

if (function == null) {

PythonContext pc = context.LanguageContext;

total = total == Undefined ? iterable.Current : pc.Add(total, iterable.Current);

yield return total;

while (MoveNextHelper(iterable)) {

total = pc.Add(total, iterable.Current);

yield return total;

}

} else {

total = total == Undefined ? iterable.Current : PythonCalls.Call(function, total, iterable.Current);

yield return total;

while (MoveNextHelper(iterable)) {

total = PythonCalls.Call(function, total, iterable.Current);

yield return total;

}

}

}

}

[PythonType]

public class chain : IterBase {

private IEnumerator ie;

private IEnumerator inner;

private chain() { }

public chain(params object[] iterables) {

SetInnerEnumerator(PythonTuple.MakeTuple(iterables));

}

[ClassMethod]

public static chain from_iterable(CodeContext/*!*/ context, PythonType cls, object iterables) {

chain res;

if (cls == DynamicHelpers.GetPythonTypeFromType(typeof(chain))) {

res = new chain();

} else {

res = (chain)cls.CreateInstance(context);

}

res.SetInnerEnumerator(iterables);

return res;

}

public PythonTuple __reduce__() {

return PythonTuple.MakeTuple(

DynamicHelpers.GetPythonType(this),

PythonTuple.EMPTY,

inner == null ? PythonTuple.MakeTuple(ie) : PythonTuple.MakeTuple(ie, inner)

);

}

public void __setstate__(PythonTuple state) {

// TODO: error handling?

ie = state[0] as IEnumerator;

inner = (state.Count > 1) ? state[1] as IEnumerator : null;

InnerEnumerator = LazyYielder();

}

private void SetInnerEnumerator(object iterables) {

ie = PythonOps.GetEnumerator(iterables);

InnerEnumerator = LazyYielder();

}

private IEnumerator<object> LazyYielder() {

while (inner != null && inner.MoveNext()) {

yield return inner.Current;

}

while (ie.MoveNext()) {

inner = PythonOps.GetEnumerator(ie.Current);

while (inner.MoveNext()) {

yield return inner.Current;

}

}

}

}

[PythonType]

public class compress : IterBase {

private compress() { }

public compress(CodeContext/*!*/ context, [NotNull]object data, [NotNull]object selectors) {

EnsureIterator(context, data);

EnsureIterator(context, selectors);

InnerEnumerator = LazyYielder(data, selectors);

}

public PythonTuple __reduce__() {

// TODO

return PythonTuple.MakeTuple(

DynamicHelpers.GetPythonType(this),

PythonTuple.MakeTuple() // arguments

);

}

private static void EnsureIterator(CodeContext/*!*/ context, object iter) {

if (iter is IEnumerable || iter is IEnumerator ||

iter is IEnumerable<object> || iter is IEnumerator<object>) {

return;

}

if (iter == null ||

!PythonOps.HasAttr(context, iter, "__iter__") &&

!PythonOps.HasAttr(context, iter, "__getitem__")) {

throw PythonOps.TypeError("'{0}' object is not iterable", PythonTypeOps.GetName(iter));

}

}

// (d for d, s in zip(data, selectors) if s)

private static IEnumerator<object> LazyYielder(object data, object selectors) {

IEnumerator de = PythonOps.GetEnumerator(data);

IEnumerator se = PythonOps.GetEnumerator(selectors);

while (de.MoveNext()) {

if (!se.MoveNext()) {

break;

}

if (PythonOps.IsTrue(se.Current)) {

yield return de.Current;

}

}

}

}

[PythonType]

public class count : IterBase, ICodeFormattable {

private int _curInt;

private object _step, _cur;

public count() {

_curInt = 0;

_step = 1;

InnerEnumerator = IntYielder(this, 0, 1);

}

public count(int start) {

_curInt = start;

_step = 1;

InnerEnumerator = IntYielder(this, start, 1);

}

public count(BigInteger start) {

_cur = start;

_step = 1;

InnerEnumerator = BigIntYielder(this, start, 1);

}

public count(int start=0, int step=1) {

_curInt = start;

_step = step;

InnerEnumerator = IntYielder(this, start, step);

}

public count([DefaultParameterValue(0)]int start, BigInteger step) {

_curInt = start;

_step = step;

InnerEnumerator = IntYielder(this, start, step);

}

public count(BigInteger start, int step) {

_cur = start;

_step = step;

InnerEnumerator = BigIntYielder(this, start, step);

}

public count(BigInteger start, BigInteger step) {

_cur = start;

_step = step;

InnerEnumerator = BigIntYielder(this, start, step);

}

public count(CodeContext/*!*/ context, [DefaultParameterValue(0)]object start, [DefaultParameterValue(1)]object step) {

EnsureNumeric(context, start);

EnsureNumeric(context, step);

_cur = start;

_step = step;

InnerEnumerator = ObjectYielder(context.LanguageContext, this, start, step);

}

private static void EnsureNumeric(CodeContext/*!*/ context, object num) {

if (num is int || num is double || num is BigInteger || num is Complex) {

return;

}

if (num == null ||

!PythonOps.HasAttr(context, num, "__int__") &&

!PythonOps.HasAttr(context, num, "__float__")) {

throw PythonOps.TypeError("a number is required");

}

}

private static IEnumerator<object> IntYielder(count c, int start, int step) {

int prev;

for (; ; ) {

prev = c._curInt;

try {

start = checked(start + step);

} catch (OverflowException) {

break;

}

c._curInt = start;

yield return prev;

}

BigInteger startBig = (BigInteger)start + step;

c._cur = startBig;

yield return prev;

for (startBig += step; ; startBig += step) {

object prevObj = c._cur;

c._cur = startBig;

yield return prevObj;

}

}

private static IEnumerator<object> IntYielder(count c, int start, BigInteger step) {

BigInteger startBig = (BigInteger)start + step;

c._cur = startBig;

yield return start;

for (startBig += step; ; startBig += step) {

object prevObj = c._cur;

c._cur = startBig;

yield return prevObj;

}

}

private static IEnumerator<BigInteger> BigIntYielder(count c, BigInteger start, int step) {

for (start += step; ; start += step) {

BigInteger prev = (BigInteger)c._cur;

c._cur = start;

yield return prev;

}

}

private static IEnumerator<BigInteger> BigIntYielder(count c, BigInteger start, BigInteger step) {

for (start += step; ; start += step) {

BigInteger prev = (BigInteger)c._cur;

c._cur = start;

yield return prev;

}

}

private static IEnumerator<object> ObjectYielder(PythonContext context, count c, object start, object step) {

start = context.Operation(PythonOperationKind.Add, start, step);

for (; ; start = context.Operation(PythonOperationKind.Add, start, step)) {

object prev = c._cur;

c._cur = start;

yield return prev;

}

}

public PythonTuple __reduce__() {

PythonTuple args;

if (StepIsOne()) {

args = PythonTuple.MakeTuple(_cur == null ? _curInt : _cur);

} else {

args = PythonTuple.MakeTuple(_cur == null ? _curInt : _cur, _step);

}

return PythonTuple.MakeTuple(DynamicHelpers.GetPythonType(this), args);

}

private bool StepIsOne() {

if (_step is int) {

return (int)_step == 1;

}

Extensible<int> stepExt;

if ((stepExt = _step as Extensible<int>) != null) {

return stepExt.Value == 1;

}

return false;

}

#region ICodeFormattable Members

public string __repr__(CodeContext/*!*/ context) {

object cur = _cur == null ? _curInt : _cur;

if (StepIsOne()) {

return string.Format("count({0})", PythonOps.Repr(context, cur));

}

return string.Format(

"count({0}, {1})",

PythonOps.Repr(context, cur),

PythonOps.Repr(context, _step)

);

}

#endregion

}

[PythonType]

public class cycle : IterBase {

public cycle(object iterable) {

InnerEnumerator = Yielder(PythonOps.GetEnumerator(iterable));

}

public PythonTuple __reduce__() {

// TODO

return PythonTuple.MakeTuple(

DynamicHelpers.GetPythonType(this),

PythonTuple.MakeTuple(), // arguments

null // state

);

}

public void __setstate__(object state) {

// TODO

}

private IEnumerator<object> Yielder(IEnumerator iter) {

PythonList result = new PythonList();

while (MoveNextHelper(iter)) {

result.AddNoLock(iter.Current);

yield return iter.Current;

}

if (result.__len__() != 0) {

for (; ; ) {

for (int i = 0; i < result.__len__(); i++) {

yield return result[i];

}

}

}

}

}

[PythonType]

public class dropwhile : IterBase {

private readonly CodeContext/*!*/ _context;

public dropwhile(CodeContext/*!*/ context, object predicate, object iterable) {

_context = context;

InnerEnumerator = Yielder(predicate, PythonOps.GetEnumerator(iterable));

}

public PythonTuple __reduce__() {

// TODO

return PythonTuple.MakeTuple(

DynamicHelpers.GetPythonType(this),

PythonTuple.MakeTuple(), // arguments

null // state

);

}

public void __setstate__(object state) {

// TODO

}

private IEnumerator<object> Yielder(object predicate, IEnumerator iter) {

PythonContext pc = _context.LanguageContext;

while (MoveNextHelper(iter)) {

if (!Converter.ConvertToBoolean(pc.CallSplat(predicate, iter.Current))) {

yield return iter.Current;

break;

}

}

while (MoveNextHelper(iter)) {

yield return iter.Current;

}

}

}

[PythonType]

public class groupby : IterBase {

private static readonly object _starterKey = new object();

private bool _fFinished = false;

private object _key;

private readonly CodeContext/*!*/ _context;

public groupby(CodeContext/*!*/ context, object iterable) {

InnerEnumerator = Yielder(PythonOps.GetEnumerator(iterable));

_context = context;

}

public groupby(CodeContext/*!*/ context, object iterable, object key) {

InnerEnumerator = Yielder(PythonOps.GetEnumerator(iterable));

_context = context;

if (key != null) {

_key = key;

}

}

public PythonTuple __reduce__() {

// TODO

return PythonTuple.MakeTuple(

DynamicHelpers.GetPythonType(this),

PythonTuple.MakeTuple(), // arguments

null // state

);

}

public void __setstate__(object state) {

// TODO

}

private IEnumerator<object> Yielder(IEnumerator iter) {

object curKey = _starterKey;

if (MoveNextHelper(iter)) {

while (!_fFinished) {

while (PythonContext.Equal(GetKey(iter.Current), curKey)) {

if (!MoveNextHelper(iter)) {

_fFinished = true;

yield break;

}

}

curKey = GetKey(iter.Current);

yield return PythonTuple.MakeTuple(curKey, Grouper(iter, curKey));

}

}

}

private IEnumerator<object> Grouper(IEnumerator iter, object curKey) {

while (PythonContext.Equal(GetKey(iter.Current), curKey)) {

yield return iter.Current;

if (!MoveNextHelper(iter)) {

_fFinished = true;

yield break;

}

}

}

private object GetKey(object val) {

if (_key == null) return val;

return _context.LanguageContext.CallSplat(_key, val);

}

}

[PythonType]

public class filterfalse : IterBase {

private readonly CodeContext/*!*/ _context;

public filterfalse(CodeContext/*!*/ context, object predicate, object iterable) {

_context = context;

InnerEnumerator = Yielder(predicate, PythonOps.GetEnumerator(iterable));

}

public PythonTuple __reduce__() {

// TODO

return PythonTuple.MakeTuple(

DynamicHelpers.GetPythonType(this),

PythonTuple.MakeTuple() // arguments

);

}

private IEnumerator<object> Yielder(object predicate, IEnumerator iter) {

while (MoveNextHelper(iter)) {

if (ShouldYield(predicate, iter.Current)) {

yield return iter.Current;

}

}

}

private bool ShouldYield(object predicate, object current) {

if (predicate == null) return !PythonOps.IsTrue(current);

return !Converter.ConvertToBoolean(

_context.LanguageContext.CallSplat(predicate, current)

);

}

}

[PythonType]

public class islice : IterBase {

public islice(object iterable, object stop)

: this(iterable, 0, stop, 1) {

}

public islice(object iterable, object start, object stop)

: this(iterable, start, stop, 1) {

}

public islice(object iterable, object start, object stop, object step) {

int startInt = 0, stopInt = -1;

if (start != null && !Converter.TryConvertToInt32(start, out startInt) || startInt < 0)

throw PythonOps.ValueError("start argument must be non-negative integer, ({0})", start);

if (stop != null) {

if (!Converter.TryConvertToInt32(stop, out stopInt) || stopInt < 0)

throw PythonOps.ValueError("stop argument must be non-negative integer ({0})", stop);

}

int stepInt = 1;

if (step != null && !Converter.TryConvertToInt32(step, out stepInt) || stepInt <= 0) {

throw PythonOps.ValueError("step must be 1 or greater for islice");

}

InnerEnumerator = Yielder(PythonOps.GetEnumerator(iterable), startInt, stopInt, stepInt);

}

public PythonTuple __reduce__() {

// TODO

return PythonTuple.MakeTuple(

DynamicHelpers.GetPythonType(this),

PythonTuple.MakeTuple(), // arguments

null // state

);

}

public void __setstate__(object state) {

// TODO

}

private IEnumerator<object> Yielder(IEnumerator iter, int start, int stop, int step) {

if (!MoveNextHelper(iter)) yield break;

int cur = 0;

while (cur < start) {

if (!MoveNextHelper(iter)) yield break;

cur++;

}

while (cur < stop || stop == -1) {

yield return iter.Current;

if ((cur + step) < 0) yield break; // early out if we'll overflow.

for (int i = 0; i < step; i++) {

if ((stop != -1 && ++cur >= stop) || !MoveNextHelper(iter)) {

yield break;

}

}

}

}

}

[PythonType]

public class zip_longest : IEnumerator {

private readonly IEnumerator[]/*!*/ _iters;

private readonly object _fill;

private PythonTuple _current;

public zip_longest(params object[] iterables) {

_iters = new IEnumerator[iterables.Length];

for (int i = 0; i < iterables.Length; i++) {

_iters[i] = PythonOps.GetEnumerator(iterables[i]);

}

}

public zip_longest([ParamDictionary]IDictionary<object, object> paramDict, params object[] iterables) {

object fill;

if (paramDict.TryGetValue("fillvalue", out fill)) {

_fill = fill;

if (paramDict.Count != 1) {

paramDict.Remove("fillvalue");

throw UnexpectedKeywordArgument(paramDict);

}

} else if (paramDict.Count != 0) {

throw UnexpectedKeywordArgument(paramDict);

}

_iters = new IEnumerator[iterables.Length];

for (int i = 0; i < iterables.Length; i++) {

_iters[i] = PythonOps.GetEnumerator(iterables[i]);

}

}

public PythonTuple __reduce__() {

// TODO

return PythonTuple.MakeTuple(

DynamicHelpers.GetPythonType(this),

PythonTuple.MakeTuple(), // arguments

null // state

);

}

public void __setstate__(object state) {

// TODO

}

#region IEnumerator Members

object IEnumerator.Current {

get {

return _current;

}

}

bool IEnumerator.MoveNext() {

if (_iters.Length == 0) return false;

object[] current = new object[_iters.Length];

bool gotValue = false;

for (int i = 0; i < _iters.Length; i++) {

if (!MoveNextHelper(_iters[i])) {

current[i] = _fill;

} else {

// values need to be extraced and saved as we move incase

// the user passed the same iterable multiple times.

gotValue = true;

current[i] = _iters[i].Current;

}

}

if (gotValue) {

_current = PythonTuple.MakeTuple(current);

return true;

}

return false;

}

void IEnumerator.Reset() {

throw new NotImplementedException("The method or operation is not implemented.");

}

public object __iter__() {

return this;

}

#endregion

}

private static Exception UnexpectedKeywordArgument(IDictionary<object, object> paramDict) {

foreach (object name in paramDict.Keys) {

return PythonOps.TypeError("got unexpected keyword argument {0}", name);

}

throw new InvalidOperationException();

}

[PythonType]

public class product : IterBase {

public product(params object[] iterables) {

InnerEnumerator = Yielder(ArrayUtils.ConvertAll(iterables, x => new PythonList(PythonOps.GetEnumerator(x))));

}

public product([ParamDictionary]IDictionary<object, object> paramDict, params object[] iterables) {

object repeat;

int iRepeat = 1;

if (paramDict.TryGetValue("repeat", out repeat)) {

if (repeat is int) {

iRepeat = (int)repeat;

} else {

throw PythonOps.TypeError("an integer is required");

}

if (paramDict.Count != 1) {

paramDict.Remove("repeat");

throw UnexpectedKeywordArgument(paramDict);

}

} else if (paramDict.Count != 0) {

throw UnexpectedKeywordArgument(paramDict);

}

PythonList[] finalIterables = new PythonList[iterables.Length * iRepeat];

for (int i = 0; i < iRepeat; i++) {

for (int j = 0; j < iterables.Length; j++) {

finalIterables[i * iterables.Length + j] = new PythonList(iterables[j]);

}

}

InnerEnumerator = Yielder(finalIterables);

}

public PythonTuple __reduce__() {

// TODO

return PythonTuple.MakeTuple(

DynamicHelpers.GetPythonType(this),

PythonTuple.MakeTuple(), // arguments

null // state

);