спрей-маршрутизации - Akka спросить с ИАС

Question

Я пытаюсь закончить службу в spray.io следующие примеры из исходной документации, и я застрял на сообщение об ошибке:

could not find implicit value for parameter marshaller: spray.httpx.marshalling.ToResponseMarshaller[scala.concurrent.Future[AdImporterServiceActor.StatusOfImport]] 


val adServiceRoute: Route = { 
    path("service"/"import"/"status") { 
     get { 
     respondWithMediaType(`text/plain`) { 
      complete { 
      adImporterService.ask(GetImportStatus)(1 second).mapTo[StatusOfImport] 
      } 
     } 
     } 
    } 
    } 

    implicit val importStatusMarshaller: Marshaller[StatusOfImport] = 
    Marshaller.of[StatusOfImport](ContentTypes.`text/plain`) { (value, contentType, ctx) => 
     val string = "Hello marshalled status" 
     ctx.marshalTo(HttpEntity(contentType, string)) 
    } 

где

case class StatusOfImport(statuses: Map[String, ImportStatus], activeRequests:Set[Import]) 

    case class ImportStatusUpdate(adId: String, statusUpdate: ImportStatus) 

Я не уверен, что мне здесь не хватает. Может ли кто-нибудь более опытный дать подсказку?

Thx

Answer 1

Я думаю, что вам нужно в рамках неявного ExecutionContext, чтобы обеспечить возможность Future сортировочной.

Answer 2

Изменить эту часть, а также import scala.concurrent.ExecutionContext.Implicits.global

respondWithMediaType(MediaTypes.`text/plain`) { ctx=> 

    (adImporterService.ask(GetImportStatus)(1 second).mapTo[StatusOfImport]).onComplete { 
       case Success(s) => ctx.complete(s) 
       case Failure(x)=> ctx.complete(StatusCodes.RequestTimeout) 
       } 
}