public static IGenerator<U> AggregateWindow<T, U>( this IGenerator<T> generator, int windowSize, Func<IEnumerable<T>, U> aggregate )