scalaz-stream

2зной

1ответ

Как объединить смежные линии с scalaz-потока без потери расщепления линии

Предположим, что мой входной файл myInput.txt выглядит следующим образом: ~~~ text1 bla bla some more text ~~~ text2 lorem ipsum ~~~ othertext the wikipedia entry is not up to date То есть,

3зной

2ответ

Как я могу ускорить обработку текста с помощью скаляз-потока?

Как я могу ускорить следующий код scalaz-stream? В настоящее время требуется около 5 минут для обработки 70 МБ текста, поэтому я, вероятно, делаю что-то совершенно неправильное, так как простой эквива

1зной

2ответ

Scalaz потока отрывов ВВЕРХ N

Учитывая очередь, как так: val queue: Queue[Int] = async.boundedQueue[Int](1000) Я хочу снять эту очередь и поток его в выходной Мойке, в кусках до 100. queue.dequeue.chunk(100).to(downstreamConsume

2зной

1ответ

Как убить входной сигнал консоли при прерывании процесса

Я играю в библиотеке Scalaz Stream и пытаюсь создать простое консольное приложение. Я следовал за учебником scalaz streams, и у них есть пример с консолью чтения и записи. Но я столкнулся со странной

1зной

1ответ

Асинхронный «узел» в потоке scalaz

У меня есть Process[Task, A], и мне нужно запустить функцию A => B которой время работы в диапазоне от мгновенного до очень долго на каждом A потока с получением Process[Task, B]. Уловка заключается в