httpsリクエスト用のakka-http cachedHostConnectionPoolをscalaで作成する方法は？

Question

httpsリクエストを送信するためのscalaを使用してakka-httpにcachedHostConnectionPoolを作成する方法を理解できません。 queueRequest(HttpRequest(uri = "https://example.com")がhttpに要求を送信すると、cachedHostConnectionPool[Promise[HttpResponse]]("https://example.com")は:が予想されない文字であるというエラーをスローします。

import scala.util.{ Failure, Success } 
import scala.concurrent.{ Future, Promise } 

import akka.actor.ActorSystem 
import akka.http.scaladsl.Http 
import akka.http.scaladsl.model._ 
import akka.stream.ActorMaterializer 
import akka.stream.scaladsl._ 

import akka.stream.{ OverflowStrategy, QueueOfferResult } 

implicit val system = ActorSystem() 
import system.dispatcher // to get an implicit ExecutionContext into scope 
implicit val materializer = ActorMaterializer() 

val QueueSize = 10 

// This idea came initially from this blog post: 
// http://kazuhiro.github.io/scala/akka/akka-http/akka-streams/2016/01/31/connection-pooling-with-akka-http-and-source-queue.html 
val poolClientFlow = Http().cachedHostConnectionPool[Promise[HttpResponse]]("example.com") 
val queue = 
    Source.queue[(HttpRequest, Promise[HttpResponse])](QueueSize, OverflowStrategy.dropNew) 
    .via(poolClientFlow) 
    .toMat(Sink.foreach({ 
     case ((Success(resp), p)) => p.success(resp) 
     case ((Failure(e), p)) => p.failure(e) 
    }))(Keep.left) 
    .run() 

def queueRequest(request: HttpRequest): Future[HttpResponse] = { 
    val responsePromise = Promise[HttpResponse]() 
    queue.offer(request -> responsePromise).flatMap { 
    case QueueOfferResult.Enqueued => responsePromise.future 
    case QueueOfferResult.Dropped  => Future.failed(new RuntimeException("Queue overflowed. Try again later.")) 
    case QueueOfferResult.Failure(ex) => Future.failed(ex) 
    case QueueOfferResult.QueueClosed => Future.failed(new RuntimeException("Queue was closed (pool shut down) while running the request. Try again later.")) 
    } 
} 

val responseFuture: Future[HttpResponse] = queueRequest(HttpRequest(uri = "/")) 

Javaであなたも（自分のテストから）プロトコルを提供することができますしながら、Scalaのバージョンのみがプレーンなホスト名をサポートしていますように思える：

http.cachedHostConnectionPool("akka.io", materializer()); 
http.cachedHostConnectionPool("https://akka.io", materializer()); 
http.cachedHostConnectionPool("https://akka.io:8080", materializer()); 

任意の既知の回避策を？

Answer 1

代わりcachedHostConnectionPoolHttpsを使用する必要があります。

val poolClientFlow = Http().cachedHostConnectionPoolHttps[Promise[HttpResponse]]("example.com")