in java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Expose.java [77:92]
private void onRequestBody(HttpServerExchange exchange, byte[] requestBytes) {
try {
CompletableFuture<Slice> future = handler.handle(Slices.wrap(requestBytes));
exchange.dispatch();
future.whenComplete(
(responseBytes, ex) -> {
if (ex != null) {
onException(exchange, ex);
} else {
onSuccess(exchange, responseBytes);
}
});
} catch (Throwable t) {
onException(exchange, t);
}
}