Как отрегулировать время отклика?

Question

В маршрутизации akka-http я могу вернуть Future в качестве ответа, который неявно преобразуется в ToResponseMarshaller.

Есть ли способ справиться с таймаутом этого будущего? Или таймаут соединения на уровне маршрута? Или один способ использовать функцию Await()?

Прямо сейчас клиент может ждать ответа навсегда.

complete { 
    val future = for { 
    response <- someIOFunc() 
    entity <- someOtherFunc() 
    } yield entity 
    future.onComplete({ 
    case Success(result) => 
     HttpResponse(entity = HttpEntity(MediaTypes.`text/xml`, result)) 
    case Failure(result) => 
     HttpResponse(entity = utils.getFault("fault")) 
    }) 
    future 
} 

Answer 1

Добавление тайм-аут, чтобы асинхронной операции означает создание нового будущего, который завершается либо самой операции, или тайм-аут:

import akka.pattern.after 
val future = ... 
val futureWithTimeout = Future.firstCompletedOf(
    future :: 
    after(1.second, system.scheduler)(Future.failed(new TimeoutException)) :: 
    Nil 
) 

Второй Будущее также может провести успешный результат, который заменяет ошибка, в зависимости от того, что именно вы хотите моделировать.

В качестве побочного примечания: представленный образец кода содержит мертвый код, регистрация обработчика onComplete в будущем имеет смысл только для побочных эффектов, но вы, похоже, хотите изменить значение будущего и создать из него HttpEntity. Это должно быть сделано с помощью map и recover:

future 
    .map(result => HttpResponse(entity = HttpEntity(MediaTypes.`text/xml`, result))) 
    .recover { case ex => HttpResponse(entity = utils.getFault("fault")) } 

Это будет затем общее возвращаемое значение, которое передается в complete директивы.