scalaz-stream

1熱度

1回答

我通過scalaz.stream.time.awakeEvery(1.second)瞭解到，我可以創建一個每秒創建一個事件的進程。非常明顯。然後，我可以將該流程映射爲每秒完成一些任務。到現在爲止還挺好。如果我想停止此活動，該怎麼辦？我試過p.kill.run.run，其中p是由time.awakeEvery(1.second)創建的過程，但它不起作用。因此，代碼如下所示： implicit v

2熱度

1回答

如何在進程中斷時終止控制檯輸入

我正在玩Scalaz Stream庫並試圖創建一個簡單的控制檯應用程序。我按照教程scalaz streams，他們有一個控制檯讀寫的例子。但是我面臨一個奇怪的問題，我不知道如何理清。這是我的代碼： import scala.concurrent.duration._ import scalaz.concurrent.Task object StreamApp extends App

3熱度

1回答

斯卡拉斯流充氣的使用示例

在以下scalaz-stream（取自documentation）的使用示例中，如果輸入和/或輸出是gzip文件，需要更改哪些內容？換句話說，我該如何使用compress？ import scalaz.stream._ import scalaz.concurrent.Task val converter: Task[Unit] = io.linesR("testdata/fahr

2熱度

1回答

如何合併相鄰的線與scalaz流不失分割線

假設我輸入文件myInput.txt如下所示： ~~~ text1 bla bla some more text ~~~ text2 lorem ipsum ~~~ othertext the wikipedia entry is not up to date 也就是說，有通過~~~分開的文件。期望的輸出如下： text1: bla bla some more text te

0熱度

1回答

從隊列中scalaz

我想跟隨在一些差距https://github.com/functional-streams-for-scala/fs2/wiki/Binding-to-asynchronous-processes 灌裝的第一個例子創建過程，並增加了一些調試打印我到了下面的代碼： import java.util.concurrent.ScheduledExecutorService import scala.

1熱度

1回答

單面變壓器與scalaz流

在這個片段y.run不typecheck。 object Test { type StateStringTask[A] = StateStringT[Task, A] type StateStringT[M[_], A] = StateT[M, String, A] val x: Process[Task, Unit] = ??? val y: Pro

0熱度

1回答

如何將Scalaz-Stream Process [F，Option [T]]轉換爲Process [F，T]？

我有一個scalaz流過程： val src = Process.repeatEval(Task(in.take())) : Process[Task, Option[T]] 如何擺脫期權？到目前爲止，我已經使用收集，但給人的感覺並不優雅： src.collect { case Some(x) => x } : Process[Task, T] 有沒有更好的辦法？

0熱度

1回答

scalaz-stream基於計算值消耗流量

我有兩個流，我希望能夠根據每運行x秒的計算來使用一個流。我想我基本上需要創建第三tick流 - 類似every(3.seconds) - ，做計算，然後拿出某種其他兩個之間的切換。我有點卡在這裏（我只是剛剛開始與scalaz-stream混在一起）。謝謝！

1熱度

2回答

Scalaz流分塊多達N

給定一個隊列像這樣： val queue: Queue[Int] = async.boundedQueue[Int](1000) 欲拉斷該隊列和它傳輸到下游水槽，在UP的組塊100。 queue.dequeue.chunk(100).to(downstreamConsumer) 作品之類的，但如果我有說101個的消息就不會清空隊列。剩下1條消息，除非另有99個消息被推入。我希望儘可能多地從

2熱度

2回答

http4s - get請求體String或InputStream的

我試圖定義HttpService接收JSON並將其與json4s庫解析到案例類： import org.http4s._ import org.http4s.dsl._ import org.json4s._ import org.json4s.native.JsonMethods._ case class Request(firstName: String, secondName: S