Пропустить()

Author: nixel2007

src/Классы/Поток.os

@@ -27,6 +27,22 @@
 	Конвейер.Добавить(Ячейка);
 
 	Возврат ЭтотОбъект;
+
+КонецФункции
+
+Функция Пропустить(Количество) Экспорт
+	
+	Лог.Отладка("Пропустить %1", Количество);
+	
+	ДополнительныеПараметры = Новый Структура;
+	ДополнительныеПараметры.Вставить("Количество", Количество);
+	
+	Ячейка = ОписанияОповещений.Создать("ВыполнитьПропустить", ЭтотОбъект, ДополнительныеПараметры);
+	
+	Конвейер.Добавить(Ячейка);
+	
+	Возврат ЭтотОбъект;
+
 КонецФункции
 
 Функция Фильтровать(ОписаниеОповещения) Экспорт
@@ -76,6 +92,20 @@
 
 КонецПроцедуры
 
+Процедура ВыполнитьПропустить(Результат, ДополнительныеПараметры) Экспорт
+	
+	Количество = ДополнительныеПараметры.Количество;
+	
+	Лог.Отладка("ВыполнитьПропустить %1", Количество);
+	
+	Результат = Новый Массив;
+	Для сч = Количество По Коллекция.ВГраница() Цикл
+		Элемент = Коллекция[сч];
+		Результат.Добавить(Элемент);
+	КонецЦикла;
+	
+КонецПроцедуры
+
 Процедура ВыполнитьФильтровать(Результат, ДополнительныеПараметры) Экспорт
 
 	Обработчик = ДополнительныеПараметры.Обработчик;
@@ -108,6 +138,7 @@
 	Результат = Новый Массив;
 	Для Каждого Ячейка Из Конвейер Цикл
 		Лог.Отладка("Выполняю ячейку конвейера %1", Ячейка.ИмяПроцедуры);
+		Лог.Отладка("Размер коллекции %1", Коллекция.Количество());
 
 		ОписанияОповещений.ВыполнитьОбработкуОповещения(Ячейка, Результат);
 		Коллекция = Результат;

test.os

@@ -20,7 +20,7 @@
 Стрим = Новый Стрим;
 Стрим.УстановитьКоллекцию(Массив);
 
-Результат = Стрим.Фильтровать(ФункцияФильтрации).Первые(2).ВМассив();
+Результат = Стрим.Пропустить(2).Фильтровать(ФункцияФильтрации).Первые(2).ВМассив();
 Для Каждого Элемент Из Результат Цикл
 	Сообщить(Элемент);
 КонецЦикла