Sign up to save your podcasts
Or
Share 147: Disposing RxJava 2 Streams with AutoDispose
Share to email
Share to Facebook
Share to X
Share to email
Share to Facebook
Share to X
Or
147: Disposing RxJava 2 Streams with AutoDispose
In this short fragment episode, Donn explains how you can clean up your RxJava 2 streams and ensure no memory leaks are occurring by using the AutoDispose library from Uber.
Shownotes
CatchUp Library
Code Samples
Java
myObservable
.map(...)
.as(AutoDispose.autoDisposable(AndroidLifecycleScopeProvider.from(this)))
.subscribe(...)
Kotlin
myObservable
.map(...)
.autoDisposable(AndroidLifcycleScopeProvider.from(this))
.subscribe(...)
With Scope Event Provided
myObservable
.map(...)
.autoDisposable(AndroidLifcycleScopeProvider.from(this, Lifecycle.Event.ON_DESTROY))
.subscribe(...)
Testing
// File: CustomerService.kt
class CustomerService @Inject constructor(...) {
lateinit var scopeProvider: ScopeProvider
}
// Usage in Fragment/Activity/etc
val service = CustomerService(...).apply {
scopeProvider = AndroidLifecycleScopeProvider.from(this)
}
// Usage in Test
val service = CustomerService(...).apply {
scopeProvider = TestScopeProvider.create()
}
Contact
View all episodes
By Donn Felker, Kaushik Gopal
5
6868 ratings
In this short fragment episode, Donn explains how you can clean up your RxJava 2 streams and ensure no memory leaks are occurring by using the AutoDispose library from Uber.
Shownotes
CatchUp Library
Code Samples
Java
myObservable
.map(...)
.as(AutoDispose.autoDisposable(AndroidLifecycleScopeProvider.from(this)))
.subscribe(...)
Kotlin
myObservable
.map(...)
.autoDisposable(AndroidLifcycleScopeProvider.from(this))
.subscribe(...)
With Scope Event Provided
myObservable
.map(...)
.autoDisposable(AndroidLifcycleScopeProvider.from(this, Lifecycle.Event.ON_DESTROY))
.subscribe(...)
Testing
// File: CustomerService.kt
class CustomerService @Inject constructor(...) {
lateinit var scopeProvider: ScopeProvider
}
// Usage in Fragment/Activity/etc
val service = CustomerService(...).apply {
scopeProvider = AndroidLifecycleScopeProvider.from(this)
}
// Usage in Test
val service = CustomerService(...).apply {
scopeProvider = TestScopeProvider.create()
}
Contact
More shows like Fragmented - Android Developer Podcast
View all
Design Details
361 Listeners
Developer Tea
402 Listeners
Does Not Compute
53 Listeners
Toolsday
48 Listeners
Swift Unwrapped
90 Listeners