ursus
10/24/2020, 9:20 PMrx:
FooRepository {
val foo: Observable<List<Foo>> by lazy {
fooDao.foo
.publish()
.autoConnect()
.replay(1)
}
}
flow:
FooRepository {
val foo: Flow<List<Foo>> by lazy {
fooDao.foo
.shareIn(scope = ???, started = SharingStarted.Lazyly())
}
}