akka-stream

2熱度

1回答

您將如何更改此Akka Streams示例以獲取物化值Future [ServerBinding]？

http://doc.akka.io/docs/akka/2.4.2/scala/stream/stream-io.html的第二個例子如下。我添加了定義host & port。 val host = "localhost" val port = 4444 val connections: Source[IncomingConnection, Future[ServerBind

3熱度

1回答

Akka-http：Http.cachedHostConnectionPoolHttps在某些時候停止處理以用於非2XX響應

我正在嘗試使用cachedHostConnectionPoolHttps發出出站https請求，但似乎在Non 2XX響應的一段時間後，池流會停止發出元素的導致整個流量停止。這種特殊行爲的發生時間非常隨機，但發生並可重現。下面是一個簡單的測試中，它的一些時間Expected OnNext(_), yet no element signaled during 10 seconds後停止發射結果被拋

0熱度

1回答

Akka Streams文檔中的循環示例不起作用

我試圖用一個簡單的循環創建一個Akka Stream。在閱讀文檔here並且沒有運氣的情況下，我嘗試將示例代碼複製爲起始基礎，但這也不起作用。代碼編譯（在包含示例中缺少的源代碼之後），但沒有打印出來。它看起來好像有些東西一直反壓，但我不明白爲什麼。這裏是我的代碼，任何幫助將是非常讚賞： import akka.actor.ActorSystem import akka.stream.{Acto

1熱度

1回答

什麼是Flow＃加入Akka Streams

4熱度

1回答

akka streaming over tcp

這裏是設置：我希望能夠通過tcp連接將消息（jsons轉換爲bytestrings）從發佈者傳輸到遠程服務器訂閱者。理想情況下，發佈者將是一個可以接收內部消息的隊列，然後將它們排隊，然後將它們流式傳輸到訂閱服務器，當然如果有突出需求的話。我明白，這需要擴展ActorPublisher類，以便在需要時向onNext()發送消息。我的問題是，到目前爲止，我只能發送（接收和解碼正確）一次性消息到服務

2熱度

1回答

mergeSubstreamsWithParallelism VS mergeSubstreams

是我首先想到的是剛剛的性能差異，但在執行此代碼 .groupBy(magicNumber, tuple => tuple._2) .fold(("", Seq.empty[String])) { case ((_, acc), tuple) => (tuple._2, acc :+ tuple._1) } .mergeSubstreams 我有給我造成一個FINIT流merg

4熱度

1回答

的ExecutionContext與

我剛開始接觸阿卡流和我試圖想辦法的mapAsync在阿卡流使用：目前，我的流量，我使用mapAsync（）與我休息服務進行整合，建議here。我一直想知道，有什麼執行上下文應mapAsync（）是使用？它應該是我的ActorSystem的調度員嗎？全球？在這兩種情況下是否有任何非顯而易見的後果？我意識到這可能是一個愚蠢的問題，但我從來沒有處理之前阿卡，並在涉及期貨的任何應用程序階，我只用

1熱度

1回答

將HttpEntity.Chunk轉換爲數組[String]

我遇到以下問題。我正在查詢某個服務器的某些數據並將其重新獲取爲HttpEntity.Chunk。字符串看起來像高達10.000.000行這樣的迴應： [{"name":"param1","value":122343,"time":45435345}, {"name":"param2","value":243,"time":4325435}, ......] 現在我想要得到的輸入數據到和

0熱度

1回答

廣播和Concat在Akka Stream中不工作

我想在Akka Stream中創建一個包含Broadcast和Concat的圖，但以下代碼不起作用。我想知道爲什麼它不起作用。 val src = Source(1 to 3) val sink = Sink.foreach(println) RunnableGraph.fromGraph(GraphDSL.create() { implicit b => impor

1熱度

1回答

阿卡流階段不執行同時

我開始學習阿卡流和我從這裏運行的第一個例子： http://doc.akka.io/docs/akka/2.4.2/scala/stream/stream-rate.html#stream-rate-scala import akka.stream.scaladsl._ import akka.actor.ActorSystem import akka.stream.ActorMaterial