@Test
public void testRemovedInstanceCleanup() {

    statusUpdateSubject.onNext(AgentStatus.healthy(MY_SOURCE, instance, "OK", testScheduler.now()));
    statusUpdateSubject.onNext(AgentStatus.terminated(MY_SOURCE, instance, "Terminated", testScheduler.now()));
    AgentStatus status = monitor.getStatus(instance.getId());
    assertThat(status.getStatusCode()).isEqualTo(AgentStatusCode.Healthy);
    assertThat(status.getDescription()).contains("No data recorded yet");
}