В какой-то момент я написал программу захвата пакетов на Haskell, и она использовала ленивый ввод-вывод для перехвата всех TCP-пакетов. Проблема заключалась в том, что иногда пакеты идут не по порядку, поэтому мне приходилось вставлять их все в...

Я хотел, чтобы немного узнать об Iteratees, заново реализовать созданный мной простой парсер, используя Data.Iteratee и Data.Attoparsec.Iteratee. Хотя я в значительной степени озадачен. Ниже у меня есть простой пример, который может анализировать...

Я пытаюсь освоить использование Iteratees в Play 2 для потоковой передачи результатов кометы. У меня есть дескриптор создания перечислителя из обратного вызова и перечислителя из карты. Моя проблема связана с Enumeratee.map, она принимает функцию,...

Я хочу применить перечисление к итерируемому, а затем вернуть исходное итерируемое, чтобы я мог применить дополнительные материалы. В документации по игре есть пример, в котором используется Iteratee[Int,Int], который просто суммирует ввод...

В проекте sbt play я запускаю console-project и вставляю этот код: import play.api.libs.iteratee._ val e = Enumerator.imperative[String]() e.push("foo") e.push("bar") e.push("bah") e.close val i: Iteratee[String, String] =...

Я пытаюсь использовать пакет scalaz iteratee для обработки большого zip-файла в постоянном пространстве. У меня есть длительный процесс, который мне нужно выполнить для каждого файла в zip-файле. Эти процессы могут (и должны) выполняться...

Я создал простую итерацию для загрузки файла с помощью WS, как описано в этой ссылке . Рассмотрим следующий фрагмент: import java.nio.ByteBuffer import java.nio.channels.FileChannel import org.specs2.mutable.Specification import...

Предположим, я читал из InputStream . Как я обычно это делаю: val inputStream = ... try { doStuff(inputStream) } finally { inputStream.close() } Независимо от того, выдает ли doStuff исключение, мы закроем файл InputStream ....

Я получил массивный массив битов, сохраненный как массив байтов, который представляет все значения int со знаком (4 294 967 295). byte[] bitArray = byte[536870912]; Каждый байт в массиве представляет 8 чисел, по одному на каждый бит. Это...

Начиная с примера из этого поста, мне интересно, как справиться с recover : def HasToken(action: String => EssentialAction): EssentialAction = EssentialAction { requestHeader => val maybeToken = requestHeader.headers.get("session")...

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

У меня есть динамически вычисляемая коллекция jsObject. val collection: Enumerator[JsObject] = ??? Я хочу преобразовать свою коллекцию в JsArray и отправить JsArray, используя кодировку передачи по частям. import...

Я использую Play Framework 2.2 и ReactiveMongo. Я перебираю все полученные записи из ReactiveMongo и получаю некоторое свойство из одной записи. Иногда выдает Exception of inexistent property, как мне его поймать, сейчас простое "восстановление" не...

Привет, я только что запустил powershell, и я работаю со сценарием powershell, который должен перебирать большой файл, содержащий строки, такие как "ABCD#######";"####";"@@";## ;"@@";####;#####;"@";. Что мне нужно сделать в powershell, так это...