¿Pasar lambdas a Observable.subscribe en kotlin dará como resultado pérdidas de memory?

Vea el siguiente código de kotlin:

class MainActivity : AppCompatActivity() { override fun onCreate(savedInstanceState: Bundle?) { val disposable = Observable.interval(1, TimeUnit.SECONDS, AndroidSchedulers.mainThread()) .subscribe { textView.text = it.toString } } }

Aquí estoy pasando una expresión lambda en el método de suscripción en lugar de una class interna anónima. Entonces, ¿es necesario llamar a disposable.dispose() para evitar pérdidas de memory? O la expresión lambda no mantendrá una reference implícita a la instancia de la class MainActivity.

Y si necesito desecharlo, ¿cuál es la mejor manera y por qué?

Agregué un registrador al Observable.subscribe () de la siguiente manera:

 class MainActivity : AppCompatActivity() { override fun onCreate(savedInstanceState: Bundle?) { val disposable = Observable.interval(1, TimeUnit.SECONDS, AndroidSchedulers.mainThread()).subscribe { Log.d(TAG, "Interval:" + it.toString()) textView.text = it.toString } } }

y notó que incluso después de salir de la aplicación presionando la tecla de retroceso, el observable seguía funcionando. Así que agregué el siguiente código a onDestroy ():

 override fun onDestroy() { disposable.dispose() super.onDestroy() }

y ahora todo está funcionando como se esperaba

Llamar a un RxJava Single In Kotlin Lambda

¿Cómo se simula emitir 2 streams infinitas observables y tener otras observables que las fusionan y amortiguan cada 10 segundos?

RxKotlin: tratando de agregar errores personalizados capturando

Cómo hacer que la function regrese Observable

Cómo escribir la testing adecuada para el repository de interfaz reactiva que devuelve Observable solo cuando hay algún evento, cómo simular el desencadenamiento de ese evento

llamar parte de la secuencia una vez con múltiples suscriptores?

RxJava BehaviorSubject no emite el último elemento?

RxJava: cómo devolver el tipo correcto de nulo

Implementando la búsqueda que empuja los resultados a la list tan pronto como estén disponibles usando rxJava

Comportamiento con Kotlin Higher-Order Functions e interfaces de método único?

Modelo lleno con respuesta extra usando Rx

¿Pasar lambdas a Observable.subscribe en kotlin dará como resultado pérdidas de memory?

Kotlin – println usando una plantilla de cadena para stderr

Igualdad en Kotlin

Encuadernación en map con KClass Type

En Kotlin, error de deserialization de Jackson con class de datos

JNI: Lectura y escritura de buffer directo

Cómo pasar object personalizado a través de bash en kotlin

Handler postDelay () desde el hilo de background

Kotlin: No se puede devolver un tipo derivado

Función de object compañera burlona en kotlin

¿Cómo diseñar para networkingucir las classs networkingundantes en Kotlin?

Manejo de events con kotlin y butterknife

Deserialization de Jackson: classs de datos de Kotlin: valores pnetworkingeterminados para campos faltantes por asignador

El uso de Spring HATEOAS ControllerLinkBuilder y Kotlin arroja IllegalArgumentException

Loop JPA array sin activar Lob fetch

Error de configuration de Kotlin