* @return a string listing referenced document titles
     */
    protected String buildSourceTitlesContent(final ChatMessage msg, final int summaryMaxChars) {
        final List<ChatSource> sources = msg.getSources();
        if (sources == null || sources.isEmpty()) {
            return buildTruncatedContent(msg, summaryMaxChars);
        }
        final int maxSuffixLen = Math.max(0, summaryMaxChars / 4);

                    .filter(p -> p.getLocation("version") != null
                            && p.getLocation("version").getSource() != null
                            && defaulModelId.equals(
                                    p.getLocation("version").getSource().getModelId()))
                    .distinct()
                    .map(Plugin::getArtifactId) // managed by us, groupId is always o.a.m.plugins

    cache.remove("a")
  }

  @Test
  fun readingTheSameStreamMultipleTimes() {
    set("a", "a", "b")
    val snapshot = cache["a"]!!
    assertThat(snapshot.getSource(0)).isSameInstanceAs(snapshot.getSource(0))
    snapshot.close()
  }

  @Test
  fun rebuildJournalOnRepeatedReads() {
    set("a", "a", "a")
    set("b", "b", "b")
    while (taskFaker.isIdle()) {

                break;
            }

            configureResolver(request.getModelResolver(), tmpModel, problems);

            ModelData parentData = readParent(tmpModel, currentData.getSource(), request, problems);

            if (parentData == null) {
                currentData = superData;
            } else if (currentData == resultData) { // First iteration - add initial id after version resolution.