Обработать()

Author: nixel2007

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

@@ -45,6 +45,25 @@
 
 КонецФункции
 
+Функция Различные() Экспорт
+	ВызватьИсключение "Не реализовано.";
+КонецФункции
+
+Функция Обработать(ОписаниеОповещения) Экспорт
+	
+	Лог.Отладка("Обработать %1", ОписаниеОповещения.ИмяПроцедуры);
+	
+	ДополнительныеПараметры = Новый Структура;
+	ДополнительныеПараметры.Вставить("Обработчик", ОписаниеОповещения);
+	
+	Ячейка = ОписанияОповещений.Создать("ВыполнитьОбработать", ЭтотОбъект, ДополнительныеПараметры);
+	
+	Конвейер.Добавить(Ячейка);
+	
+	Возврат ЭтотОбъект;
+
+КонецФункции
+
 Функция Фильтровать(ОписаниеОповещения) Экспорт
 
 	Лог.Отладка("Фильтровать %1", ОписаниеОповещения.ИмяПроцедуры);
@@ -131,6 +150,29 @@
 
 КонецПроцедуры
 
+Процедура ВыполнитьОбработать(Результат, ДополнительныеПараметры) Экспорт
+	
+	Обработчик = ДополнительныеПараметры.Обработчик;
+	
+	Лог.Отладка("ВыполнитьОбработать %1", Обработчик.ИмяПроцедуры);
+	
+	Результат = Новый Массив;
+	
+	Если Обработчик.ДополнительныеПараметры = Неопределено Тогда
+		Обработчик.ДополнительныеПараметры = Новый Структура;
+	КонецЕсли;
+	Обработчик.ДополнительныеПараметры.Вставить("Элемент");
+	
+	Для Каждого Элемент Из Коллекция Цикл
+		Обработчик.ДополнительныеПараметры.Элемент = Элемент;
+		РезультатОбработки = Неопределено;
+		ОписанияОповещений.ВыполнитьОбработкуОповещения(Обработчик, РезультатОбработки);
+		
+		Результат.Добавить(РезультатОбработки);
+	КонецЦикла;
+	
+КонецПроцедуры
+
 Процедура ПройтиКонвейер()
 
 	Лог.Отладка("Прохожу по конвейеру");

test.os

@@ -6,7 +6,14 @@
 	Результат = Элемент > 3;
 КонецПроцедуры
 
+Процедура ОбработчикОбработки(Результат, ДополнительныеПараметры) Экспорт
+	Элемент = ДополнительныеПараметры.Элемент;
+	Результат = Элемент + 1;
+	Сообщить("Я - операция map, и это мое послание миру: элемент " + Элемент + " превратился в " + Результат);
+КонецПроцедуры
+
 ФункцияФильтрации = ОписанияОповещений.Создать("ОбработчикФильтрации", ЭтотОбъект);
+ФункцияОбработки = ОписанияОповещений.Создать("ОбработчикОбработки", ЭтотОбъект);
 
 Массив = Новый Массив;
 Массив.Добавить(3);
@@ -20,7 +27,13 @@
 Стрим = Новый Стрим;
 Стрим.УстановитьКоллекцию(Массив);
 
-Результат = Стрим.Пропустить(2).Фильтровать(ФункцияФильтрации).Первые(2).ВМассив();
+Результат = Стрим
+	.Пропустить(2)
+	.Фильтровать(ФункцияФильтрации)
+	.Первые(2)
+	.Обработать(ФункцияОбработки)
+	.ВМассив();
+
 Для Каждого Элемент Из Результат Цикл
 	Сообщить(Элемент);
 КонецЦикла