Mocking Activity Lifecycle для RxJava в модульном тесте

Question

В настоящее время разрабатывается приложение для Android с использованием RxJava.

я получил следующий фрагмент кода:

public Observable<Response<DTO>> getDTO(final BaseActivity activity, final long workorderId) { 
    return dtoService.getDTO(DTOId) 
      .subscribeOn(Schedulers.io()) 
      .compose(activity.bindUntilEvent(ActivityEvent.PAUSE)) 
      .observeOn(AndroidSchedulers.mainThread()); 
} 

(. Пожалуйста, не против именования объектов, просто поставить некоторые случайные имена, чтобы отразить то, что нужно делать)

I протестировать отдельные части кода. Более того, эти части не содержат метод .compose(). Теперь я попытался следующие:

@Mock 
private BaseActivity baseActivity; 

@Before 
public void setup() { 
    MockitoAnnotations.initMocks(this); 
} 

и

private BaseActivity baseActivity; 

@Before 
public void setup() { 
    baseActivity = Mock(BaseActivity.class); 
} 

Обе эти ситуации дают мне нулевой указатель: lifecycle == null (Что это, если я его отладки).

Как я обманываю или проверяю это каким-либо другим способом? (Кроме того, я не совсем понимаю, метод Compose(). Но я не могу показаться, чтобы найти какие-либо ресурсы, связанные с этим кодом)

(I при условии, что планировщики Android и RxJava, так что это не проблема)

Спасибо!

Answer 1

Хорошо, так. Начнем с метода . Что он делает - применяет некоторую функцию трансформатора к вашему Observable, которую вы можете понимать как «объединить пользовательскую последовательность наблюдаемых методов (например, map, flatMap и т. Д.)». То есть вы можете использовать его для объединения .subscribeOn и .observeOn методов (more here). Поскольку вы используете RxLifecycle, вы можете просто перейти к исходному коду и посмотреть, what it does.

Если вы хотите использовать жизненный цикл деятельности в тестах, вы должны использовать Robolectric. Это даст вам полный контроль над созданием активности и управлением ее жизненным циклом. Это поможет с NPE. Вы просто настроить его и написать:

ActivityController controller = Robolectric.buildActivity(BaseActivity.class).create().start().resume(); 
Activity activity = controller.get(); 

// Not paused yet 
activityController.pause(); 
// Pause happened! Do something! 

Надеется, что это помогает (?.