ContextPropagation.java

ServerBuilder sb = ...;
sb.service("/api", (ctx, req) -> {
    CompletableFuture<HttpResponse> future = new CompletableFuture<>();
    HttpResponse authResponse = authClient.execute(req.headers());
    // 서드파티 API의 응답을 다른 쓰레드에서 비동기로 처리한다.
    authResponse.aggregate().thenAccept(aggregatedRes -> {
        // 요청 컨텍스트 정보를 명시적으로 전달한다.
        try (SafeCloseable ignored = ctx.push()) {
            HttpResponse response = backendClient.execute(req);
            future.complete(response);
        }
    });
    return HttpResponse.from(future);
};