public static void main()

in java/connectors/uniswap/src/main/java/com/epam/deltix/data/connectors/uniswap/UniswapDataConnector.java [58:102]

37 lines of code
1 McCabe index (conditional complexity)


    public static void main(String[] args) throws Exception {
        final UniswapDataConnector dataConnector = new UniswapDataConnector(
                new UniswapConnectorSettings(
                        "uniswap",
                        "dxtick://localhost:8011",
                        "uniswap"
                )
        );

        DataConnector.DEBUG_OUTPUT_FACTORY = () -> new CloseableMessageOutput() {
            @Override
            public void close() {
                System.out.println("Close the message output");
            }

            @Override
            public void send(final InstrumentMessage message) {
                System.out.println(message);
            }
        };

        final MdModel model = dataConnector.model();

        final MdModel.Availability availability = model.available();
        dataConnector.logger().info(() -> availability.toString());

        dataConnector.subscribe(
                model.select().
                        withCustom(
                                FactoryAction.class,
                                BundleAction.class,
                                PoolAction.class,
                                TokenAction.class,
                                PositionAction.class,
                                TickAction.class).
                        build(),
                "BUSD/WETH"
        );

        System.in.read();

        dataConnector.close();

        dataConnector.logger().info(() -> "CLOSED");
    }