0
val system = ActorSystem("test")
val http = IO(Http)(system)
def fetch = http ! HttpRequest(GET, "http://0.0.0.0:8080/loadtest")
如果我是這樣做:
(0 to 25).foreach(_ => fetch)
我期望代碼將火過25個異步請求。會發生什麼反而是四個請求被設置。他們等待迴應。當對全部4的響應回來時,再發送4個,直到處理全部25個。
我試着用噴霧的配置創建一個自定義調度調整,但這並沒有影響......
outbound-http-dispatcher {
type = Dispatcher
executor = "thread-pool-executor"
throughput = 250
}
spray.can {
host-connector-dispatcher = outbound-http-dispatcher
manager-dispatcher = outbound-http-dispatcher
}
如何配置阿卡/噴塗到異步發送關閉所有25個請求?
使用:阿卡2.2.3,噴霧1.2.0