Я только начал изучать Play 2.0 Framework. Единственное, чего я просто не могу понять, так это паттерна Iteratee, Enumerator и Enumeratee, описанного в руководстве по игре . У меня очень мало опыта работы с функциональными языками. Что делает...

Мне действительно сложно понять основные цели Iteratee и Enumerator в Play. я прочел Общие сведения о итерациях Play2 для обычных людей Итераторы Счетчики Я прочитал этот ответ и обнаружил, что вместо модели вытягивания,...

Чтение документации о Play Framework и ReactiveMongo заставляет меня поверить, что ReactiveMongo работает таким образом, что использует мало потоков и никогда не блокируется. Однако кажется, что связь приложения Play с сервером Mongo должна...

Я пытаюсь составить Enumeratee.grouped и Enumeratee.filter , чтобы создать новый перечислитель, однако я столкнулся с проблемой дисперсии. Типы ввода и вывода моего перечисления - это ADT, и я получаю следующую ошибку. <console>:24:...

Я хочу использовать Play2 для загрузки очень больших файлов CSV (миллионы строк) в elasticsearch. Я написал следующий код, который отлично работает. Меня не устраивает то, как я пропускаю заголовок ответа http в первом фрагменте. Должен быть...

Я ищу способ распечатать тело ответа в рамках Play, у меня есть такой код: object AccessLoggingAction extends ActionBuilder[Request] { def invokeBlock[A](request: Request[A], block: (Request[A]) => Future[Result]) = {...

Я работаю над приложением чата, используя WebSockets (в Play 2.3 с scala). Сообщение должно быть передано всем пользователям или определенному набору пользователей на основе входящего сообщения. Один пользователь может участвовать более чем в одном...

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

Я нахожу документы Олега по Iteratee довольно сложными для понимания. Тем более, что некоторые функции в его сообщениях для Haskell-Cafe отсутствуют в библиотеке iteratee (например, enum_file ). Есть ли где-нибудь хорошее введение в iteratee,...

Можно ли создать несколько Enumerators из одного Enumerator ? Я ищу эквивалент List.partition , который возвращает (List[A], List[A]) , например List().partition(_.age >= 18) Поэтому в идеале я хотел бы применить преобразование к...

У меня есть алгоритм с отслеживанием состояния, который постепенно принимает ввод и постепенно производит вывод. Входы и выходы не связаны по количеству; т. е. вход может производить ноль или более выходов. Я пытаюсь превратить его в Enumeratee...

У меня есть бесконечный поток с сообщениями, представленными как Plays Enumerator , к которым я применяю Iteratee . Затем каждое сообщение обрабатывается актором Akka (количество актеров ограничено 10). Теперь я хотел бы, чтобы код в Iteratee...

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

Интересно, как идиоматически повторить java.util.HashSet в Scala. В настоящее время я использую итераторы java в цикле while, который не кажется отличным. Кроме того, мне интересно, эффективен ли изменяемый расширяемый буфер или есть ли...

Чтение http://reactivemongo.org/releases/0.11/documentation/tutorial/consume-streams.html в нем говорится Метод apply в Enumerator имеет псевдоним оператора |>>>. Поэтому мы можем переписать последнюю строку следующим образом:...