akka-stream

4熱度

1回答

我一直試圖在網上澄清這個問題一段時間沒有成功，所以我會試着在這裏問一下。我想找到一些資源或示例，說明如何構建端到端完全反壓REST服務+客戶端。我的意思是，我希望看到，給定一個實現響應流的REST客戶端（無論是Akka，JS還是其他），我將（並且能夠「可視化」）整個過程中處理的背壓建立REST服務器，例如與Akka-Http。要清楚，我正在尋找類似下面的通話（但我找不到幻燈片或視頻進行確認）：

2熱度

2回答

在Akka-Streams中分流內流

我正在想出一個解決方案，將我收到的串流分成多個Strings。我一直在研究，看起來在Akka-Streams的早期版本中，有一個Transformer類，你可以擴展來做這種類型的轉換。在我使用的版本（RC2）中有Stage s，但我不確定如何實現分割模式。 Source.actorPublisher[String](MyActor.props). .XXXXX(_.split("\n"))

3熱度

2回答

將回調方法實現轉換爲akka流源

我正在從不受控制的java庫中發佈數據。發佈程序庫使用典型的回調設置;某處庫代碼（該庫是Java，但我將在階描述簡潔）： type DataType = ??? trait DataConsumer { def onData(data : DataType) : Unit } 的庫的用戶編寫實現的onData方法並傳遞到一個DataProducer一類需要，庫代碼看起來類似：

5熱度

1回答

有沒有辦法讓Akka-Stream獲得可預測的演員命名？

我使用ActorPublisher作爲Akka-Stream Source。我無法弄清楚如何預測輸入參數的名稱，以便從應用程序的其他部分發送消息。我在我的實例源像這樣： val src = Source[Task](Props(classOf[TaskListener], this), "task-listener") 我得到一個ActorRef當我兌現流，而是動態地生成它的路徑，它僅使用我提

0熱度

2回答

集成與阿卡流基於ACK的演員

我已設計有阿卡-IO ACKING工作的演員，使得上游發送消息（到網絡）時，它會等待ACK。該角色是後端的異步應用程序的接口。我想有一層包裝，讓我這個演員轉換成阿卡流Flow[Incoming, Outgoing, ???]，使可以與期望這樣的簽名更新的圖書館集成。（從上游收到的消息是罕見的，所以我們不關心太多太多關於backpressuring有，但它不會是一件壞事擁有它。）

2熱度

1回答

測試阿卡反應流

我測試代碼哪些流通過獲得一個多輸出流的TCP連接的消息： (IO(StreamTcp) ? StreamTcp.Connect(settings, address)) .mapTo[StreamTcp.OutgoingTcpConnection] .map(_.outputStream) 在測試中，我與虛擬用戶替換所得Subscriber[ByteString]，引發一些傳出消息，並聲稱已

7熱度

1回答

阿卡-HTTP使用油滑3.0 Databasepublisher

我使用光滑3.0和有databasepublisher對象 def getAsStream = db.stream[Entity](tblquery.result) 我使用阿卡-HTTP休息層如下， val route = path("stream"){ get { complete { // how to stream from here } } } 如何流可以

1熱度

1回答

阿卡流OnNext不允許

我只是跟着ActorPublisher例如阿卡流，有時我得到這個消息： java.lang.IllegalStateException：當流沒有要求的元素onNext是不允許的，totalDemand在0 看文檔，他們解釋：通過調用onNext發送元素的流。您可以發送發送與流客戶請求的元素一樣多的元素。這個金額可以用totalDemand查詢。當isActive和totalDemand>

0熱度

1回答

在Scala中替換線程執行程序池

我的應用程序要求我有多個線程運行從各個HDFS節點獲取數據。爲此，我使用線程執行程序池並分叉線程。在分叉： val pathSuffixList = fileStatuses.getOrElse("FileStatus", List[Any]()).asInstanceOf[List[Map[String, Any]]] pathSuffixList.foreach(block =>

38熱度

1回答

如何創建可以通過方法調用稍後接收元素的源？

我想在其上創建Source，後來推元素，如在： val src = ... // create the Source here // and then, do something like this pushElement(x1, src) pushElement(x2, src) 什麼是推薦的方式做到這一點？謝謝！