RxJava Observable Zip вызывает утечку памяти

Question

Я использую метод Observable.zip RxJava для объединения двух вызовов API в один результат. По какой-то причине я получаю утечку памяти, несмотря на то, что я отписываюсь от подписки. Я не уверен, что это ошибка на моем конце, или если есть что-то, что мне нужно сделать с созданием Observable.

protected void onCreate(Bundle bundle) { 
... 

subscription = Observable.zip(
     api.getConfiguration(), 
     api.getSettings().map(r -> r.getData()), 
     new Func2<ConfigurationResponse, List<Datum>, Struct>() { 
     @Override 
     public Struct call(ConfigurationResponse config, List<Datum> data) { 
      return new Struct(data, config.getCopy(), config.getSettings()); 
     } 
     } 
    ) 
     .compose(Schedulers.applyApiSchedulers()) 
     .subscribe(
     struct -> { 
      configurationManager.set(struct.data, struct.copy, struct.settings); 
      startNextActivity(); 
     }, 
     error -> { 
      startNextActivity(); 
     } 
    ); 
} 

protected void onDestroy() { 
    if (!subscription.isUnsubscribed()) { 
    subscription.unsubscribe(); 
    } 
} 

Вот след от утечки канарейки.

Любая помощь будет оценена.

Answer 1

Я подозреваю, что утечка исходит от самого subscription, поскольку вы, похоже, продолжаете ссылаться на Subscriber через него. Попробуйте очистить эту ссылку в onDestroy и снова проверить утечки.

Answer 2

Это, вероятно, утечка в модификации, похоже, что было похоже here.

Обратите внимание, что если модернизация утечки абонента, вы можете ограничить воздействие, если функция mapper больше не ссылается на ваш экземпляр активности. В вашем случае Struct, вероятно, является нестатистическим классом экземпляра (следовательно, имеет неявную ссылку на экземпляр активности), если вам удастся сделать его статическим без ссылки на активность, вы, скорее всего, избавитесь от этой самой утечки.