akka-stream

2熱度

1回答

的目標是實現與此簽名 def bindedSinkAndSource[A]:(Sink[A, Any], Source[A, Any]) = ??? 在返回源發射無論匯接收功能的來源。我的主要目標是通過handleWebSocketMessages指令實現websocket轉發器。轉發器圖爲： leftReceiver ~> rightEmitter leftEmitter <~ rig

1熱度

1回答

如何綁定akka http與akka流？

我試圖使用流，而不是純粹的演員來處理HTTP請求和我用下面的代碼來： trait ImagesRoute { val log = LoggerFactory.getLogger(this.getClass) implicit def actorRefFactory: ActorRefFactory implicit def materializer: ActorM

0熱度

1回答

阿卡流鏈接在一起，流，每個發出HTTP請求

我有一個響應這些兩個URI /posts/{id} : get a blog post by ID /comments?postId={id} : get all the comments on a blog by the blog's id 與一批博客ID的啓動寧靜的博客服務器（http://jsonplaceholder.typicode.com），我想創建一個流動的是執行該程序的步

0熱度

1回答

找到：akka.http.scaladsl.server.StandardRoute [錯誤] required：scala.util.Try

我是新來的斯卡拉和阿卡我想發佈端點。發生編譯錯誤。 found: akka.http.scaladsl.server.StandardRoute [error] required: scala.util.Try[Option[com.activegrid.entities.AuthSettings]] => (akka.http.scaladsl.server.RequestContext =>

1熱度

1回答

阿卡HTTP流監聽一段時間後，停止處理數據字節

我有具有3個HTTP監聽器像這樣的一個應用程序： val futureResponse1: Future[HttpResponse] = Http().singleRequest(HttpRequest(uri = someUrl)) 各3的正在偵聽到非止動流（每個爲不同的一種）。並用同組開始的簡單流程，然後比較快的處理（非阻塞）處理它： futureResponse1.flatMa

5熱度

1回答

如何讀取akka-http中的查詢參數？

我知道akka-http庫編組和處理請求時類類型解組。但現在，我需要讀取GET請求的請求參數。我試過parameter()方法和它返回ParamDefAux類型，但我需要這些值作爲字符串類型我檢查答案在下面的問題。 How can I parse out get request parameters in spray-routing? Query parameters for GET reque

2熱度

1回答

如何將字節串轉換爲源[字節串，任意]

我收到來自Kafka反應流消費者的Bytestring文件;我想用這個Bytestring構造一個akka-http請求作爲實體HttpEntity.Default。 HttpEntity.Default需要Source [Bytestring，Any]作爲其參數之一。什麼是連接兩者的最佳方式？

0熱度

1回答

如何使用Akka-Stream在「反應性卡夫卡」中分塊並重新分配大型郵件

使用Kafka發送大型文件時，是否可以將其分配到分區中，然後使用Akka-Stream重新組裝？ http://www.slideshare.net/JiangjieQin/handle-large-messages-in-apache-kafka-58692297

0熱度

1回答

Supervision.Restart和Supervision.Resume之間的區別是什麼？

Supervision.Restart和Supervision.Resume真的有什麼區別嗎？這是情況。我有來自Source(List(1, 2, 3))的3個元素。在runForeach我拋出異常，如果元素是2。對於Supervision.Restart我預計只處理1。但奇怪的是我看到3達到水槽。爲什麼？我使用的是阿卡2.4.11 import akka.actor.{ActorRef, Ac

1熱度

1回答

向數據庫提供反應型API

如何爲不支持流式傳輸的數據庫提供反應型流API？比如讓我們說例如dynamodb。在進行致電時，dynamodb將返回所有結果。所以，即使我在Source中包含get調用，如何處理下游階段的背壓？另外我如何實現寫調用到數據庫？我的水槽會是什麼樣子？任何指針都會有幫助。