public static void main()

in java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Expose.java [37:63]

• 22 lines of code
• 1 McCabe index (conditional complexity)

  public static void main(String... args) {
    StatefulFunctionSpec stockFn =
        StatefulFunctionSpec.builder(StockFn.TYPE)
            .withValueSpec(StockFn.STOCK)
            .withSupplier(StockFn::new)
            .build();

    StatefulFunctionSpec userShoppingCartFn =
        StatefulFunctionSpec.builder(UserShoppingCartFn.TYPE)
            .withValueSpec(UserShoppingCartFn.BASKET)
            .withSupplier(UserShoppingCartFn::new)
            .build();

    StatefulFunctions functions = new StatefulFunctions();
    functions.withStatefulFunction(stockFn).withStatefulFunction(userShoppingCartFn);
    RequestReplyHandler handler = functions.requestReplyHandler();

    /* This example uses the Undertow http server, but any HTTP server/framework will work as-well */
    Undertow server =
        Undertow.builder()
            .addHttpListener(1108, "0.0.0.0")
            .setHandler(new UndertowStateFunHandler(handler))
            .setServerOption(ENABLE_HTTP2, true)
            .build();

    server.start();
  }