Как получить уведомление, когда нефильтрованный сервер Netty фактически завершает работу?

Question

У меня есть сервер Unfiltered Netty, который мне нужно отключить и перезапустить после каждого теста.

val mockService = unfiltered.netty.Server.http(mockServicePort).handler(mockServicePlan) 

before { 
    proxyServer.start() 
} 

after { 
    proxyServer.stop() 
} 

В настоящее время это не работает, и я абсолютно уверен, что это потому, что функция stop() неблокирующая и поэтому следующий start() функция вызывается в начале.

Я искал способ заблокировать или получить уведомление о закрытии сервера, но он не появился бы через текущий API.

Есть ли лучший способ достичь того, чего я пытаюсь достичь?

Answer 1

Простой ответ: замените ваш сервер Unfiltered Netty сервером HTTP4S Blaze.

var server: org.http4s.server.Server = null 

val go: Task[Server] = org.http4s.server.blaze.BlazeBuilder 
    .bindHttp(mockServicePort) 
    .mountService(mockService) 
    .start 

before { 
    server = go.run 
} 

after { 
    server.shutdown.run 
} 

Существует также awaitShutdown, который блокируется до тех пор, пока сервер не выключится. Но так как shutdown - это Task, его можно легко получить, когда он закончит. Просто flatMap что дерьмо.