@Test
public void shouldCreateAggregateFromEmptyStream() {

    when(eventStream.read()).thenReturn(Stream.empty());
    when(eventStream.getId()).thenReturn(STREAM_ID);
    TestAggregate aggregate = aggregateService.get(eventStream, TestAggregate.class);
    assertThat(aggregate, notNullValue());
    assertThat(aggregate.recordedEvents(), empty());
    verify(logger).trace("Recreating aggregate for instance {} of aggregate type {}", STREAM_ID, TestAggregate.class);
}