Терминальные методы - Количество, ДляКаждого, Минимум, Максимум, Сократить

Author: nixel2007

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

@@ -85,6 +85,102 @@
 	КонецЦикла;
 
 	Возврат Результат;
+
+КонецФункции
+
+Функция Количество() Экспорт
+	
+	Лог.Отладка("Количество");
+	
+	ПройтиКонвейер();
+	
+	Результат = Коллекция.Количество();
+	
+	Возврат Результат;
+
+КонецФункции
+
+Функция ДляКаждого(ОписаниеОповещения) Экспорт
+	
+	Лог.Отладка("ДляКаждого");
+	
+	ПройтиКонвейер();
+	
+	Результат = Новый Массив;
+	ДополнительныеПараметры = Новый Структура;
+	ДополнительныеПараметры.Вставить("Обработчик", ОписаниеОповещения);
+	
+	ВыполнитьОбработать(Результат, ДополнительныеПараметры);
+	
+	Возврат Результат;
+
+КонецФункции
+
+Функция Минимум(ОбработчикСравнения = Неопределено) Экспорт
+	
+	Лог.Отладка("Минимум");
+	
+	Если ОбработчикСравнения = Неопределено Тогда
+		ОбработчикСравнения = СтандартныйОбработчикСравнения();
+	КонецЕсли;
+
+	ПройтиКонвейер();
+	
+	Результат = Новый Массив;
+	ДополнительныеПараметры = Новый Структура;
+	ДополнительныеПараметры.Вставить("Обработчик", ОбработчикСравнения);
+	
+	ВыполнитьСортировать(Результат, ДополнительныеПараметры);
+	
+	Если Результат.Количество() = 0 Тогда
+		Возврат Неопределено;
+	Иначе
+		Возврат Результат[0];
+	КонецЕсли;
+
+КонецФункции
+
+Функция Максимум(ОбработчикСравнения = Неопределено) Экспорт
+	
+	Лог.Отладка("Максимум");
+	
+	Если ОбработчикСравнения = Неопределено Тогда
+		ОбработчикСравнения = СтандартныйОбработчикСравнения();
+	КонецЕсли;
+	
+	ПройтиКонвейер();
+	
+	Результат = Новый Массив;
+	ДополнительныеПараметры = Новый Структура;
+	ДополнительныеПараметры.Вставить("Обработчик", ОбработчикСравнения);
+	
+	ВыполнитьСортировать(Результат, ДополнительныеПараметры);
+	
+	Если Результат.Количество() = 0 Тогда
+		Возврат Неопределено;
+	Иначе
+		Возврат Результат[Результат.Количество() - 1];
+	КонецЕсли;
+	
+КонецФункции
+
+Функция Сократить(Обработчик, НачальноеЗначение = Неопределено) Экспорт
+
+	Лог.Отладка("Сократить");
+	
+	ПройтиКонвейер();
+
+	Результат = НачальноеЗначение;
+	Для Каждого Элемент Из Коллекция Цикл
+		Если Обработчик.ДополнительныеПараметры = Неопределено Тогда
+			Обработчик.ДополнительныеПараметры = Новый Структура;
+		КонецЕсли;
+		Обработчик.ДополнительныеПараметры.Вставить("Элемент", Элемент);
+		ОписанияОповещений.ВыполнитьОбработкуОповещения(Обработчик, Результат);
+	КонецЦикла;
+
+	Возврат Результат;
+
 КонецФункции
 
 // Служебные процедуры и функции

test.os

@@ -12,8 +12,14 @@
 	Сообщить("Я - операция map, и это мое послание миру: элемент " + Элемент + " превратился в " + Результат);
 КонецПроцедуры
 
+Процедура ОбработчикСокращения(Результат, ДополнительныеПараметры) Экспорт
+	Элемент = ДополнительныеПараметры.Элемент;
+	Результат = Результат + Элемент;
+КонецПроцедуры
+
 ФункцияФильтрации = ОписанияОповещений.Создать("ОбработчикФильтрации", ЭтотОбъект);
 ФункцияОбработки = ОписанияОповещений.Создать("ОбработчикОбработки", ЭтотОбъект);
+ФункцияСокращения = ОписанияОповещений.Создать("ОбработчикСокращения", ЭтотОбъект);
 
 Массив = Новый Массив;
 Массив.Добавить(3);
@@ -59,3 +65,7 @@
 Для Каждого Элемент Из Результат Цикл
 	Сообщить(Элемент);
 КонецЦикла;
+
+Стрим = Потоки.ИзКоллекции(Массив);
+Результат = Стрим.Обработать(ФункцияОбработки).Сократить(ФункцияСокращения, 0);
+Сообщить(Результат);