Akka-Http WebSocket：Akka流使用WebSocket作爲接收器

Question

使用Akka-Http和Akka-Streams版本2.4我如何構造一個流，使其具有一個接收器，它是一個websocket。

例如，我想要一個生成隨機數的源代碼，這些數字會被過濾，讓我們說保存偶數，然後作爲接收器流入WebSocket。

感謝

Answer 1

此代碼放入阿卡HTTP路線將輸出隨機數的連續流沒有壓倒WebSocket的爲例如

path("randomNums") { 
    val src = 
    Source.fromIterator(() => Iterator.continually(ThreadLocalRandom.current.nextInt())) 
      .filter(i => i > 0 && i % 2 == 0).map(i => TextMessage(i.toString)) 

    extractUpgradeToWebsocket { upgrade => 
     complete(upgrade.handleMessagesWithSinkSource(Sink.ignore, src)) 
    } 
}