iteratee

1зной

1ответ

Как исключение catch с использованием Iteratee.foreach в будущем

Я использую Play Framework 2.2 и ReactiveMongo. Я повторяю все полученные записи от ReactiveMongo и получаю некоторое свойство из одной записи. Иногда он выдает исключение из несуществующего свойства,

0зной

1ответ

Написание пользовательских Enumeratee с Scala и Play2

У меня с трудом понимается концепция Iteratee/Enumeratee/Enumerator. Похоже, я понял, как создать пользовательский Iteratee - есть несколько хороших примеров, таких как that. Теперь я собираюсь написа

0зной

1ответ

Итерация через дерево avl

В настоящее время я пишу на AVL-tree и пишу итератор-метод, чтобы перебирать все дерево в предварительном порядке. И я получаю NullPointer, если обрабатываю строку «stack.empty()» и не знаю, почему. И

2зной

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](

0зной

1ответ

trait Enumeratee является инвариантным по типу From when using ADT

Я пытаюсь составить Enumeratee.grouped и Enumeratee.filter, чтобы создать новый enumeratee, однако я столкнулся с проблемой отклонения. Типы ввода и вывода моего enumeratee являются ADT, и я получаю с

0зной

1ответ

Как подождать свободного акка Акка при обработке потока данных с использованием пьес Iteratee

У меня бесконечный поток с сообщениями, представленными как Плейки Enumerator, к которым я применяю Iteratee. Каждое сообщение затем обрабатывается аккой Аккой (количество участников ограничено 10). Т

1зной

1ответ

Как условно добавить новые счетчики в существующих SCALA Enumerator

Моего стек: Scala 2.11.6, 0.11.6 ReaciveMongo, Играть 2.4.2, 3.0.4 Монго У меня есть список запросов к Монго, которые Мне нужно выполнить условно один за другим (если количество результатов меньше MAX

1зной

1ответ

Потоковые данные между узлами кластера akka

Мне нужно передавать данные между парой сотен КБ и многими МБ между узлами кластера akka. Самый простой подход - разделить его на фрагментированные сообщения, но это кажется целесообразным, поскольку

0зной

1ответ

Как восстановить ошибку из будущего в EssentialAction

Начиная с примером из this поста, я задаюсь вопросом, как бороться с recover: def HasToken(action: String => EssentialAction): EssentialAction = EssentialAction { requestHeader => val maybeToken