Achèvement de la source [ByteString, _] dans Akka-Http

Question

Je voulais utiliser Alpakka pour gérer le téléchargement et le téléchargement de S3 avec Akka Steams. Cependant, je suis resté coincé avec l'utilisation de Source produite par S3Client dans les routes Akka Http. Le message d'erreur que je reçois est:

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

Je suppose qu'il est quelque chose trivial ennuyeux, comme manquer l'importation implicite, mais je n'a pas pu localiser avec précision ce que je suis absent.

J'ai créé quelques exemples minimum pour illustrer la question:

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) 
} 

Avez-vous des suggestions, que puis-je essayer? J'utilise

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

Answer 1

Vous devez créer un HttpEntity de la source, et lui donner un type de contenu.

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