アッカのHttpクライアント型の不一致

Question

私は次のエラーを取得しています、なぜ誰も私に言うことができる？：

[error] HttpClient.scala:117: type mismatch; 
[error] found : akka.stream.scaladsl.Sink[(akka.http.scaladsl.model.StatusCode, String),scala.concurrent.Future[(akka.http.scaladsl.model.StatusCode, String)]] 
[error] required: akka.stream.Graph[akka.stream.SinkShape[(akka.http.scaladsl.model.StatusCode, String)],scala.concurrent.Future[akka.http.scaladsl.model.StatusCode]] 
[error]  source.via(flow).runWith(Sink.head) 
[error]         ^

をここではコードです：

implicit def map2entity: ToEntityMarshaller[Map[String, Any]] = mapMarshaller(MediaTypes.`application/json`) 

def mapMarshaller(mediaType: MediaType.WithFixedCharset): ToEntityMarshaller[Map[String, Any]] = 
    Marshaller.withFixedContentType(mediaType) { m => HttpEntity(mediaType, JSONObject(m).toString()) } 

def post(path: String, entity: Map[String, Any]): Future[StatusCode] = { 
    val uri = Uri(getResourceUri(path)) 
    logger.info(s"httpPost: $uri") 
    Marshal(entity).to[RequestEntity] flatMap { e => 
    val source = Source.single(HttpRequest(
     uri = uri.path.toString, 
     method = HttpMethods.POST, 
     entity = e)) 

    val flow = getConnection(uri.scheme)(uri.authority.host.address) 
     .mapAsync(10) { r => 
     //(r.status -> Marshal(r.entity).to[String]) 
     Unmarshal(r.entity).to[String].flatMap(s => Future(r.status -> s)) 
     } 

    source.via(flow).runWith(Sink.head) 
    } 
} 

Answer 1

あなたのシンクのマテリアライズド値（Future[(StatusCode, String)]）であるが、 （Future[StatusCode]）で宣言した戻り値の型とは異なります。 ...だから私は変更P：post機能のみステータスコードを返す必要があるあなたの場合は

は、あなたがこのコール

.map(_ => r.status)