scalaz-stream

6熱度

1回答

scalaz-stream中的Bucketed接收器

我正在嘗試做一個接收器來寫入流到bucketed文件的流：達到特定條件（時間，文件大小等）時，當前輸出流將關閉並且新的存儲文件被打開。 我檢查瞭如何在io對象中創建不同的接收器，但沒有太多示例。所以我試圖按照如何編寫resource和chunkW。我結束了下面的一段代碼，爲了簡單起見，現在桶只是由Int表示，但最終會是某種類型的輸出流。 val buckets: Channel[Task, Str

scala scalaz scalaz-stream 2014-03-31

---

6熱度

2回答

運行scalaz-stream的Process給出了參數C的隱式值：scalaz.Catchable [F2]？

爲什麼在執行P(1,2,3).run時會收到以下error: could not find implicit value for parameter C: scalaz.Catchable[F2]？ [scalaz-stream-sandbox]> console [info] Starting scala interpreter... [info] import scalaz.stream

scala scalaz-stream 2014-04-07

---

6熱度

2回答

停止在用戶輸入

我試圖寫入以下功能 def haltOnUserInput[O](process: Process[Task, O]): Process[Task, O] 在用戶發送上stdin一行其停止process一個Process [任務，O]。在這種情況下，可以在結束進程本身之前等待進程中的當前計算結束。 我曾嘗試以下： scala> :paste // Entering paste mode (c

scala scalaz scalaz-stream 2014-07-16

---

3熱度

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: scala

stream scalaz tee scalaz-stream 2014-02-19

---

5熱度

1回答

什麼是scalaz流等同於播放框架的Enumerator.fromCallback

播放框架的iteratee庫定義的方法Enumerator.fromCallback，其允許基於一個未來的結果中產生的元素： http://www.playframework.com/documentation/2.2.x/Enumerators def fromCallback[E]( retriever:() => Future[Option[E]], onComplete:

scala scalaz scalaz-stream 2014-04-12

---

4熱度

1回答

斯卡拉斯流組排序數據庫結果

我在我的代碼中看到一個常見模式。我已經從數據庫排序結果，我需要在嵌套結構中發出它們。我希望能夠流式傳輸，所以我希望一次只能在內存中記錄很少的記錄。使用TravesableLike.groupBy假定數據未被排序，因此它不必要地填充可變映射。我想保持這種真正的流媒體。 scalaz-stream在這裏有用嗎？ val sql = """select grandparent_id, parent_id

scala scalaz scalaz-stream 2013-09-30

---

2熱度

1回答

用chunk和zipWithIndex在scalaz-stream中令人費解的行爲

我想用一個昂貴的操作※使用scalaz-stream處理數據流。 scala> :paste // Entering paste mode (ctrl-D to finish) def expensive[T](x:T): T = { println(s"EXPENSIVE! $x") x } ^D // Exiting paste mo

scala scalaz scalaz7 scalaz-stream 2014-04-25

---