사용자 정의 개체를 사용하는 대신 HttpResponse에

Question

때 그때 내가 그러나

val futureResponse = pipeline(Post(url, body)) futureResponse.map(_.status) 

를 사용하여 같은 HttpResponse에의 객체를 상태 코드를 얻을 수

val pipeline: HttpRequest => Future[HttpResponse] = addHeader(.......) ~> sendReceive ~>  unmarshal[HttpResponse]   

를 사용할 때 응답 코드를 얻는 방법, 때

val pipeline: HttpRequest => Future[MyResponse] = addHeader(.......) ~> sendReceive ~>  unmarshal[MyResponse] 

이

012를 사용 : 나는 사용자 정의 Unmarshaller에를 사용

val myfutureResponse = pipeline(Post(url, body)) 
myutureResponse.map(_.status) 

상태를 찾을 수 없으므로 컴파일되지 않습니다. 상태 코드는 어떻게 얻습니까? 내 json 결과를 deserialize 수 있도록 사용자 지정 unmarshaller 사용해야합니다.

Answer 1

마지막으로 나는

은 내가 길에서이 문제를 가지고 이제

val pipeline: HttpRequest => HttpResponse = addHeader(.......) ~> sendReceive 
val searchResponse = pipeline(Post(urlwithpath, queryString)).map { 
    response => response.status match { 
    case StatusCodes.OK => 
     Some(unmarshal[MyResponse](response)) 
    case StatusCodes.NotFound => print(StatusCodes.NotFound) 
    } 
} 

로 내 파이프 라인 방식을 변경하여 제안

private def unmarshal[T: Unmarshaller](response: HttpResponse): T = { 
response.entity.as[T] match { 
    case Right(value) => value 
    case Left(error) ⇒ throw new PipelineException(error.toString) 
} 

}에 따라 답을 발견 나는 API를 제대로 배울 것입니다.

Answer 2

파이프 라인에서 언 마셜 러를 하드 코딩하면 상태 코드를 얻을 수 없습니다. Future이 실패하게되는 예외의 일부이기 때문에 여전히 실패 코드가 발생합니다.

정말 그 정보를 유지하고 당신이이 종류의 응답을 제공 할 수 있습니다 자신의 취소 마샬를 작성해야합니다 파이프 라인에서 취소 마샬을 사용하려면 :

case class Wrapper[T](response: T, status: StatusCode) 

val pipeline: HttpRequest => Future[Wrapper[MyResponse]] = addHeader(.......) ~> sendReceive ~> myUnmarshall[MyResponse] 

이를 스프레이 내부를 모르는 경우 매우 까다로울 수 있습니다. 또 다른 옵션은 파이프 라인에 unmarshall 비트를 하드 코드하지 않고 수동으로 JSON을 비 직렬화하는 것입니다.