@Test
public void shouldContainCorrectValueForTransformInExecutorMidFlow() {

  final Repository<List<Integer>> repository = repositoryWithInitialValue(INITIAL_VALUE)
      .observe()
      .onUpdatesPerLoop()
      .getFrom(listSource)
      .goTo(new SyncExecutor())
      .thenTransform(new AddTwoForEachFunction())
      .compile();
  updatable.addToObservable(repository);
  assertThat(repository, has(LIST_PLUS_TWO));
}