Описание тега scalaz-stream
NoneScalaz-stream is a streaming I/O library. The design goals are compositionality, expressiveness, resource safety, and speed. The design is meant to supersede or replace older iteratee or iteratee-style libraries.
1
ответ
В скалярном потоке, как я могу превратить процесс [Task, Seq<B>] в Process1[Task,B]
У меня есть процесс [Задача,A]. A содержит Seq of Bs case class A(elems:Seq[B]) Я хотел бы превратить процесс [задача, A] в процесс [задача,B] def streamOfAs:Process[Task,A] = ??? streamOfBs1:Process[Task,Member] = streamOfAs.flatMap(Process.emit(_.…
11 дек '14 в 22:24
1
ответ
Скал-стрим tcp `echo` приложение не работает
Я пишу эхо-приложение, которое send а также receive '\0' завершенная строка https://gist.github.com/jilen/10a664cd588af10b7d09 object Foo { implicit val S = scalaz.concurrent.Strategy.DefaultStrategy implicit val AG = tcp.DefaultAsynchronousChannelG…
07 фев '15 в 06:14
1
ответ
Применить канал N раз от начального значения
У меня есть функция f и канал c def f(i: Int) = Task.now(i + 1) val c = channel.lift(f) Я хотел бы постоянно применять функцию f произвольное количество раз (или бесконечно) на выходе предыдущего вычисления. Я предоставляю начальную стоимость. Я мог…
18 сен '15 в 22:26
1
ответ
В scalaz-stream, как я могу выполнить задачу, когда Sink завершен?
Я скопировал пример из http4s: // Print received Text frames, and, on completion, notify the console val sink: Sink[Task, WebSocketFrame] = Process.constant { case Text(t) => Task.delay(println(t)) case f => Task.delay(println(s"Unknown type: …
13 янв '15 в 10:20
1
ответ
Непрерывно извлекать результаты базы данных с помощью scalaz.stream
Я новичок в скале и чрезвычайно новичок в скалазе. Благодаря другому ответу на стековый поток и некоторому ручному хранению я смог использовать scalaz.stream для реализации Процесса, который будет непрерывно извлекать результаты API Twitter. Теперь …
04 июн '15 в 16:40
0
ответов
Как я могу недетерминированно сгладить бесконечные потоки FS2
Я использую потоковую библиотеку Scala FS2. у меня есть Stream[F, [Stream[F, A]] где и внутренние потоки и внешний поток бесконечны (с соответствующими Async случаи для F). Я хочу закончить с Stream[F, A] который одновременно извлекается из внешнего…
04 окт '17 в 18:41
1
ответ
Производительность подсчета строк в скаляр-потоке
Я перевел код обязательного подсчета строк (см. linesGt1) с начала 15-й главы Функционального программирования в Scala до решения, использующего scalaz-stream (см. linesGt2). Производительность linesGt2 Однако это не так здорово. Императивный код пр…
17 сен '13 в 14:49
1
ответ
Моделирование FSM через преобразователь Process1?
У меня есть конечный автомат, который я хотел бы смоделировать с использованием скалярного потока Process1. Конечный автомат моделирует поток сообщений между клиентом и сервером. Базовый набор типов данных может быть: sealed trait ServerState case o…
05 мар '15 в 05:29
1
ответ
Асинхронный "узел" в скаляр-потоке
У меня есть Process[Task, A]и мне нужно запустить функцию A => B время выполнения которого варьируется от мгновенного до очень длинного на каждом A потока, чтобы дать Process[Task, B], Подвох в том, что я хотел бы обработать каждый A как можно ск…
11 авг '15 в 09:29
2
ответа
Использование scalaz-stream для расчета дайджеста
Поэтому мне было интересно, как я мог бы использовать scalaz-stream для генерации дайджеста файла, используя java.security.MessageDigest? Я хотел бы сделать это, используя постоянный размер буфера памяти (например, 4 КБ). Я думаю, я понимаю, как нач…
19 авг '14 в 23:21
2
ответа
Остановка процесса [Task, O] при вводе пользователем
Я пытаюсь написать следующую функцию def haltOnUserInput[O](process: Process[Task, O]): Process[Task, O] который останавливает process когда пользователь отправляет строку на stdin, В этом сценарии можно дождаться завершения текущих вычислений в про…
16 июл '14 в 19:45
0
ответов
Этот процесс напоминает сканирование, но я не уверен, что это... так?
Я создал процесс, чтобы помочь мне разобрать файлы журналов. Файлы журнала должны быть помечены строковым тегом. Ни одна запись не может предоставить этот строковый тег, поэтому мне нужно поддерживать некоторое состояние для каждого события журнала,…
19 фев '15 в 17:15
1
ответ
Монадные трансформеры со скалаз-потоками
В этом фрагменте y.run не проверяет object Test { type StateStringTask[A] = StateStringT[Task, A] type StateStringT[M[_], A] = StateT[M, String, A] val x: Process[Task, Unit] = ??? val y: Process[StateStringTask, Unit] = ??? x.run // This typechecks…
30 июл '16 в 01:27
1
ответ
Слияние процессов ввода скалярного потока, похоже, "ждет" на стандартном вводе
У меня есть простая программа: import scalaz._ import stream._ object Play extends App { val in1 = io.linesR("C:/tmp/as.txt") val in2 = io.linesR("C:/tmp/bs.txt") val p = (in1 merge in2) to io.stdOutLines p.run.run } Файл as.txt содержит пять aс и ф…
18 ноя '14 в 16:57
1
ответ
Метод добавления из скалярного потока, вызывающий бесконечный цикл
Я использую этот код с сайта скалярного потока, он работает с методом, но он не работает, когда я пытаюсь использовать append, он выглядит как бесконечный цикл и никогда не заканчивается. Причина, по которой я хочу использовать метод добавления, сос…
23 окт '14 в 03:39
2
ответа
Как мне объединить два потока скалаза с помощью селектора предикатов?
Я хотел бы объединить два потока скалаза с предикатом, который выбирает следующий элемент из любого потока. Например, я хотел бы пройти этот тест: val a = Process(1, 2, 5, 8) val b = Process(3, 4, 5, 7) choose(a, b)(_ < _).toList shouldEqual List…
13 июл '16 в 13:32
1
ответ
Как вы объединяете несколько Scalaz-Streams так, что порядок завершения сохраняется, но чередование не применяется?
var num =0 var num2 = 3333 val p2 = Process.eval { Thread.sleep(10000) Task.delay { Thread.sleep(10000) num2 = num2 + 1 s"hi ${num2}" } }.repeat.take(15) //p2: scalaz.stream.Process[[x]scalaz.concurrent.Task[x],String] = // Await(scalaz.concurrent.T…
19 фев '14 в 18:56
0
ответов
Скалярный поток: параллельная мультипоточка
Я только начал использовать библиотеку scalaz-stream и хотел бы реализовать следующий сценарий. У меня есть компонент, который читает некоторые события из исходного потока (очередь скаляр), изменяет его состояние и отправляет некоторые сообщения вне…
23 апр '18 в 23:55
0
ответов
scalaz-stream: объединение очередей на основе размера одной очереди
В моем приложении параллельно работают до N потребителей и один производитель. Потребители получают ресурсы от производителя, выполняют свою работу, добавляют результаты к updateQueue и попросить больше ресурсов. Первоначально у источника есть некот…
08 май '15 в 13:18
1
ответ
Scala fs2 Потоки с чанками и задачами?
// Simulated external API that synchronously returns elements one at a time indefinitely. def externalApiGet[A](): A = ??? // This wraps with the proper fs2 stream that will indefinitely return values. def wrapGetWithFS2[A](): Stream[Task, A] = Str…
21 дек '16 в 19:30