В настоящее время мы обновляем наше приложение для Android с RX1 до RX2.Однако некоторые тесты основаны на методе Observer.onSubscribe (), который больше не поддерживается в RX2.Как мы можем получить подписчиков на Observable в RX2?Мы ничего не можем найти!
Вот фрагмент.Довольно маленький, но все, что мы можем поделиться:
private static class TestSubscribe<T> implements Observable.OnSubscribe<T> {
Set<Subscriber<? super T>> mSubscribers = new HashSet<>();
@Override
public void call(Subscriber<? super T> subscriber) {
mSubscribers.add(subscriber);
}
}