currentData = parentData;
            }
        }

        problems.setSource(inputModel);
        checkPluginVersions(lineage, request, problems);

        // inheritance assembly
        assembleInheritance(lineage, request, problems);

        Model resultModel = resultData.getModel();

        problems.setSource(resultModel);
        problems.setRootModel(resultModel);

        // model interpolation

                    .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()) {