http4s가 미래에 주어진 다른 상태 코드를 수행 할 수 있습니까?

Question

나는 http4s를 사용하고, 나는 응답을 일부 JSON 데이터를 생성하는 Try 있습니다

이

case GET -> Root/"something" => 
    getSomethingTry() match { 
    case Success(something) => Ok(something) 
    case Failure(CustomNotFoundException(reason)) => NotFound(reason) 
    case Failure(CustomConflictException()) => Conflict() 
    } 

이 기능이 제대로 나는 Future로 Try을 대체 할, 그러나, Task[Response]

을 반환합니다 . 경기가 끝나면 미래가 해결되지 않았기 때문에 경기는 더 이상 작동하지 않습니다. 그래서, 나는 미래에 매핑 할 수 있습니다 :

case GET -> Root/"something" => 
    getSomethingFuture().map { 
    something => Ok(something) 
    }.recover { 
    case CustomNotFoundException(reason) => NotFound(reason) 
    case CustomConflictException() => Conflict() 
    } 

을하지만이 http4s가 원하는 것이 아니다 이는 Future[Task[Response]]을 반환합니다. Future을 unbox하려면 Await.result을 사용하는 것이 적절하지 않은 것 같습니다. 이것이 스레드 풀 문제를 일으킬 수 있다고 생각합니다. 그러나 코드가 작동하도록 만듭니다.

case GET -> Root/"something" => 
    Ok(getSomethingFuture()) 

을하지만이 날 다른 오류의 경우에 다른 상태 코드를 설정하지 않습니다

http4s는 작업 작성자의 인수로 선물을 받아들입니다. 해결 방법은 작업에서 .recover을 수행하는 것이지만 분명히 할 수는 없습니다.

다른 Future 실패 사례가 발생할 경우 어떻게 다른 http4s 태스크 래퍼를 호출 할 수 있습니까? 미들웨어를 사용해야합니까?

Answer 1

http4s 0.17 이상을 사용한다고 가정하면 Task은 fs2.Task입니다.

그것은 후자로 FutureTask로 변환 한 후 거래를 쉽게 :

내가 권하고 싶습니다

case GET -> Root/"something" => 
    Task.fromFuture(getSomethingFuture()) 
    .flatMap { 
     something => Ok(something) 
    } 
    .handleWith { 
     case CustomNotFoundException(reason) => NotFound(reason) 
     case CustomConflictException() => Conflict() 
    } 

, 그러나, 당신은 그나마 Try 또는 Future

Answer 2

대신 프로그램을 통해 Task를 사용하는 미래를 푸는 데 정말로 필요합니다. Play 프레임 워크는 Future를 반환하기위한 action.async를 제공합니다.

당신이이 우수

Action.async { 
    getSomethingFuture().map { 
    something => Ok(something) 
    }.recover { 
    case CustomNotFoundException(reason) => NotFound(reason) 
    case CustomConflictException() => Conflict() 
    } 
} 

https://www.playframework.com/documentation/2.6.x/ScalaAsync#returning-futures