scalaz-stream

2зной

2ответ

http4s - получить тело запроса в виде строки или InputStream

Я пытаюсь определить HttpService, который принимает JSON и разбирает его случае класс с json4s библиотеки: import org.http4s._ import org.http4s.dsl._ import org.json4s._ import org.json4s.native.J

7зной

1ответ

Как преобразовать Iterator в поток scalaz?

Предположим, у меня есть Iterator[A]. Я хотел бы преобразовать его в Process[Nothing, A] из scalaz stream. import scalaz.stream._ def foo[A](it: Iterator[A]): Process[Nothing, A] = ??? Как вы бы о

1зной

1ответ

Как остановить процесс ScalaZ, созданный time.awakeEvery?

Я узнал, что по scalaz.stream.time.awakeEvery(1.second) Я могу создать процесс, который создает событие каждую секунду. Совершенно очевидно. Затем я смогу сопоставить этот процесс для выполнения каждо

0зной

1ответ

Scalaz потока скобка закрывается ресурс раннего

Рассмотрим этот код: import java.time.Instant import scalaz.concurrent.Task import scalaz.stream._ class MyResource { println("resource obtained") @volatile var v = 1 def rea

0зной

2ответ

побочные эффекты для `wye` комбинаторах при использовании` halt` из scalaz-потока

filter (который использует halt внутри) завершает другой ветви, даже если она имеет некоторые побочные эффекты: scala> val p = Process("1","2", "3") scala> val p1 = p.filter(_ => true).map(_ + "p1").

1зной

1ответ

Монад-трансформаторы со сказовыми потоками

В этом фрагменте y.run не отображается тип. object Test { type StateStringTask[A] = StateStringT[Task, A] type StateStringT[M[_], A] = StateT[M, String, A] val x: Process[Task, Unit]