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