public BybitFeed()

in java/connectors/bybit/src/main/java/com/epam/deltix/data/connectors/bybit/BybitFeed.java [23:74]


    public BybitFeed(
            final String uri,
            final int depth,
            final MdModel.Options selected,
            final CloseableMessageOutput output,
            final ErrorListener errorListener,
            final Logger logger,
            final String... symbols) {

        super("BYBIT",
                uri,
                depth,
                30000,
                selected,
                output,
                errorListener,
                logger,
                getPeriodicalJsonTask(),
                symbols);

        endpoint = BybitEndpoint.typeFromAddress(uri);
        subscriptionLimit = 100;
        if (endpoint != null) {
            if (endpoint == BybitEndpoint.Spot) {
                subscriptionLimit = 5;

                if (depth == 1) {
                    subscriptionBookDepth = 1;
                } else if (depth <= 50) {
                    subscriptionBookDepth = 50;
                } else {
                    subscriptionBookDepth = 200;
                }
            } else if (endpoint == BybitEndpoint.Linear || endpoint == BybitEndpoint.Inverse) {
                if (depth == 1) {
                    subscriptionBookDepth = 1;
                } else if (depth <= 50) {
                    subscriptionBookDepth = 50;
                } else if (depth <= 200) {
                    subscriptionBookDepth = 200;
                } else {
                    subscriptionBookDepth = 500;
                }
            } else if (endpoint == BybitEndpoint.Option) {
                if (depth <= 25) {
                    subscriptionBookDepth = 25;
                } else {
                    subscriptionBookDepth = 100;
                }
            }
        }
    }