Akka-Httpでソース[ByteString、_]を完成

Question

私はS3アップロードを処理するためにAlpakkaを使い、Akka Steamsでダウンロードしたいと思っていました。しかし、私は、S3ClientがAkka Httpルートで作成したSourceを使用することに固執しました。私が取得エラーメッセージは次のとおりです。

[error] found : akka.stream.scaladsl.Source[akka.util.ByteString,_$1] where type _$1 
[error] required: akka.http.scaladsl.marshalling.ToResponseMarshallable 
[error]  complete(source) 

私は暗黙のインポートが欠落ように、それはいくつかの迷惑な些細な事であると仮定し、私は、私が行方不明です何を正確に特定することができませんでした。

私は、問題を説明するために、いくつかの最低限の例を作成しました：

import akka.actor.ActorSystem 
import akka.http.scaladsl.Http 
import akka.http.scaladsl.server.Directives._ 
import akka.stream.ActorMaterializer 
import akka.stream.scaladsl.Source 
import akka.util.ByteString 

import scala.concurrent.ExecutionContext 

class Test { 

    implicit val actorSystem: ActorSystem = ActorSystem() 
    implicit val materializer: ActorMaterializer = ActorMaterializer() 
    implicit val executionContext: ExecutionContext = actorSystem.dispatcher 

    val route = (path("test") & get) { 
    def source: Source[ByteString, _] = ??? // just assume that I am able to get that value 
    complete(source) // here error happens 
    } 

    Http().bindAndHandle(route, "localhost", 8000) 
} 

あなたはいくつかの提案を持っていますか、私は何を試すことができますか？私は、あなたがソースからHttpEntityを作成し、それをコンテンツタイプを与える必要が

libraryDependencies += "com.typesafe.akka"%% "akka-http" % "10.0.5" 

Answer 1

を使用しています。

complete(HttpEntity(ContentTypes.`application/json`, source))