android - single - rxkotlin

Si se realiza la llamada onComplete para un Asunto RxJava, ¿tengo que cancelar mi suscripción manualmente nuevamente?

Question

Estoy usando un objeto de reproducción RxJava en mi fragmento.

Estoy intentando usar ReplaySubject de una manera, donde me gustaría que el sujeto ejecute un proceso hasta que se complete (posiblemente más allá de la vida útil del fragmento).

Al finalizar el proceso, me gustaría liberar los recursos que, según tengo entendido, se anula la suscripción de la suscripción en el momento de registrar al observador (que, en mi caso, es el tema en sí).

En este tema de github, @benjchristensen dice:

Si es un Observable, entonces debería emitir un onCompleted y hacerse.

Si es un Observador, debe cancelar la suscripción a la Suscripción que recibió cuando se llamó Observable.subscribe y le dará al Observable la oportunidad de cerrar y limpiar.

Si es un Sujeto, que es tanto un Observador como un Observable, ¿cuál es el comportamiento? Si llamo aCompletar sobre el tema, ¿eso significa básicamente que la suscripción está detenida y, por lo tanto, me siento aliviado de tener que cancelar la suscripción manualmente de la suscripción que obtengo al registrar el observador?

Answer 1

Los sujetos son una capa relativamente delgada sobre un Observable que le permite alimentar las onNext() , onCompleted() y onError() desde una fuente externa al Observable. Su comportamiento de darse de baja es el mismo que un observable. Si se onCompleted() o onError() en el Asunto, se cancelará la suscripción de los suscriptores. No es necesario llamar a unsubscribe() en la suscripción devuelta por Observable.subscribe() .

Para un ReplaySubject , tenga en cuenta que los recursos no se limpiarán hasta que se recolecte la basura. Incluso después de que se haya llamado a onCompleted() en un ReplaySubject , un suscriptor aún puede suscribirse y recibirá todas las onNext() originales onNext() , onCompleted() o onError() que se realizaron antes de la suscripción.