in java/ws-server/src/main/java/com/epam/deltix/tbwg/webapp/services/grafana/GrafanaServiceNewImpl.java [292:322]
public DynamicList listStreams(String template, int offset, int limit) {
DynamicList result = new DynamicList();
List<String> list = new ObjectArrayList<>();
result.setList(list);
result.setHasMore(false);
List<String> streams;
if (StringUtil.isEmpty(template)) {
streams = Arrays.stream(timebase.listStreams())
.map(DXTickStream::getKey)
.filter(this::isKeyAccepted)
.sorted()
.skip(offset)
.collect(Collectors.toList());
} else {
streams = Arrays.stream(timebase.listStreams())
.map(DXTickStream::getKey)
.filter(this::isKeyAccepted)
.filter(key -> key.toLowerCase().contains(template.toLowerCase()))
.sorted()
.skip(offset)
.collect(Collectors.toList());
}
for (String stream : streams) {
if (list.size() == limit) {
result.setHasMore(true);
break;
}
list.add(stream);
}
return result;
}