reactive-streams

    1熱度

    1回答

    撰寫流程圖

    我一直在玩Akka Streams，並得到創建Flow s並使用FlowGraph s將它們連接在一起的想法。 我知道Akka的這部分還在開發中，所以有些東西可能無法完成，其他一些位可能會改變，但是可以創建一個不完整的FlowGraph - 即不附加到一個Sink - 並將其傳遞給我的代碼的不同部分，通過添加Flow來擴展它，最後通過添加一個Sink來完成？ 基本上，我希望能夠編寫FlowGrap
    akka reactive-streams 2014-12-06

    4熱度

    1回答

    端到端反應流式RESTful服務（又名背壓HTTP）

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

    2熱度

    1回答

    測試阿卡反應流

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

    8熱度

    2回答

    如何使用Reactive Streams進行NIO二進制處理？

    是否有一些代碼示例使用org.reactivestreams庫來處理使用Java NIO（用於高性能）的大型數據流？我瞄準分佈式處理，所以使用Akka的例子是最好的，但我可以弄清楚。 它似乎仍然是這種情況，大多數（我希望不是全部）的讀取階度假村文件Source（非二進制）或直接的Java NIO的例子（甚至之類的東西Files.readAllBytes！） 也許我錯過了一個激活模板？ （Akka
    scala akka nio reactive-streams 2015-01-05
最新問題