private void onRequestBody()

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);
      }
    }