@Test
public void testNotStarted() {

  clock.setTime(idleTimeMs - 1);
  watchdog.run();
  Assert.assertNull(call.cancelMessage);
  clock.setTime(idleTimeMs);
  watchdog.run();
  Assert.assertNotNull(call.cancelMessage);
  call.listener.onClose(
      Status.CANCELLED.withDescription("Some upstream exception representing cancellation"),
      new Metadata());
  Assert.assertEquals(
      listener.closeStatus.getDescription(), "Some upstream exception representing cancellation");
}