Вопросы с тегом 'iterate'

2

Scalaz повторяет: "Подъем" `EnumeratorT` для соответствия "IterateeT" для "большей" монады

Если у меня есть EnumeratorT и соответствующий IterateeT, я могу запустить их вместе: val en: EnumeratorT[String, Task] = EnumeratorT.enumList(List("a", "b", "c")) val it: IterateeT[String, Task, Int] = IterateeT.length (it &= en).run : Task[I...
13 нояб. '14 в 17:21
2

Потоковая передача данных одновременно и по одному HTTP-соединению в игре

потоковая передача данных из игры довольно проста. здесь быстрый пример того, как я намереваюсь это сделать (пожалуйста, дайте мне знать, если я делаю это неправильно): def getRandomStream = Action { implicit req => import scala.util.Random ...
11 дек. '13 в 15:02
1

"Добавление" элемента в Enumerator через Enumeratee

Я действительно чувствую, что делаю то, что невозможно по дизайну, но я действительно хочу полностью понять, как работают Play Iteratees... В настоящее время я пишу функцию, которая применяет некоторые преобразования в Enumerator через Enumeratee. ...
04 февр. '14 в 22:25
1

Понимание аргументов Concurrent.unicast

Я использую Play Framework 2.2 Чтобы реализовать соединение с WebSocket, я использую Concurrent.unicast который соответствует моим потребностям: val enumerator = Concurrent.unicast[JsValue] { channel => userIdWithChannelMap += u.id -> cha...
29 апр. '14 в 17:38
1

Elegant Iteratee → Перечислитель переадресации в Play

Я хотел написать приложение в Play! framework 2.2.x как упражнение в асинхронном подходе и пакет play.api.libs.iterattee. То, что я хотел сделать, это получить запрос POST с большой загрузкой файла в его теле и отправить его, кусок куском, в качеств...
05 мая '14 в 23:07
4

Вещательные сообщения в веб-форматах Play Framework

Я Concurrent.unicast[JsValue] сообщения в Concurrent.unicast[JsValue] Play Framework с помощью Concurrent.unicast[JsValue], и я хочу оптимизировать отправку одного и того же сообщения нескольким пользователям. Возможно ли транслировать сообщение, ис...
04 июл. '14 в 14:25
1

Reactivemongo: как обрабатывать исключение, которое происходит внутри Iteratee.fold

похоже, что перечисления reacitvemongo неправильно обрабатывают исключения. В приведенном ниже коде используется перечислитель (возвращаемый драйвером reactivemongo) для создания списка, проблема заключается в том, что при наличии исключения внутри ...
20 июл. '14 в 22:40
1

Как удалить EOF из Enumerator

Я хочу объединить два Enumerator. Проблема в том, что >>> и andThen не работают, если первый имеет EOF. Полагаю, я должен отказаться от EOF, но я не знаю, как это сделать. Я предполагаю, что существует общий, идиоматический способ сделать...
01 авг. '14 в 6:54
1

Как объединить данные из Enumerators - Scala

Я использую enumerator/iteratee из платформы Play. У меня есть несколько счетчиков, каждая из которых предоставляет отсортированную последовательность значений. Я хочу написать Iteratee/Enumeratee, который объединяет значения из этих счетчиков, чтоб...
30 сент. '14 в 9:04
1

Создание Enumeratee из алгоритма состояния

У меня есть алгоритм с сохранением состояния, который постепенно принимает входные данные и постепенно производит вывод. Входы и выходы не имеют отношения к числу; т.е. вход может давать ноль или более выходов. Я пытаюсь превратить его в Enumerate...
03 янв. '15 в 21:08
1

Найдите разницу между двумя счетчиками с отсортированными записями в scala

Учитывая два scala play перечисления A и B, каждый из которых предоставляет отсортированные целые числа, существует ли способ получить перечислитель целых чисел, существующих в B, которые не существуют в A? Например: val A: Enumerator[Int] = Enumer...
16 янв. '15 в 14:50
1

Play Enumeratee, который подсчитывает и отображает значения из ввода Enumerator

Мне интересно, как лучше всего реализовать что-то подобное с помощью библиотеки Play Iteratee: def sampleEvery[A](i: Int): Enumeratee[A, Int] = ??? так что, учитывая поток A s, Enumeratee будет считать их и испускать текущее значение для этого сче...
03 авг. '15 в 14:51
0

Остановка перечислений и итераторов в PlayFramework при закрытии запроса

Я использую перечисления в приложении Play Framework. Когда запрос отправляется на конкретный URI, я вызываю MongoService (используя responseivemongo), который возвращает перечислитель, и этот результат затем отправляется через HTTP-поток, используя...
28 окт. '15 в 16:00
1

Как создать Iteratee, который передает значения во внутреннее Iteratee, если не найдено определенное значение

У меня есть ADT, который по существу является крестом между Option и Try: sealed trait Result[+T] case object Empty extends Result[Nothing] case class Error(cause: Throwable) extends Result[Nothing] case class Success[T](value: T) extends Result[T] ...
25 нояб. '15 в 12:50
1

Как читать и обрабатывать фрагмент файла куском для каждого этапа процесса с помощью Play Iteratees

Я использую play framework Iteratee для чтения файла. Я хотел бы обработать этот фрагмент файла куском (для каждого шага). Я составляю следующие шаги: groupByLines: Enumeratee[Array[Byte], List[String]] turnIntoLines: Enumeratee[List[String], Lis...
26 сент. '16 в 16:27