@Test
public void testFindTaskWithRelocationDataFetchTimeout() {

    when(relocationServiceClient.findTaskRelocationPlan(TASK1.getId())).thenReturn(Mono.never());
    ExtTestSubscriber<Task> testSubscriber = new ExtTestSubscriber<>();
    taskRelocationDataInjector.injectIntoTask(TASK1.getId(), Observable.just(TASK1)).subscribe(testSubscriber);
    testSubscriber.assertOpen();
    testScheduler.advanceTimeBy(RELOCATION_TIMEOUT_MS, TimeUnit.MILLISECONDS);
    assertThat(testSubscriber.takeNext()).isEqualTo(TASK1);
    testSubscriber.assertOnCompleted();
}