RxJava stream transformation

Question

I have the following functions declared in the repo:

fun loadAllNotifications(): Single<List<Notification>> fun insertAll(notifications: List<Notification>): Completable

What I'd like to do is to loadAllNotifications() and then for each Notification reset its isOpened flag to false by doing something like

val updatedNotification = currentNotification.copy(isOpened = false)

Once I have a list of Notifications with the isOpened set to false, I'd like to pass this list into insertAll(list)

How would I do the above in a single RxChain? Any help will be greatly appreciated.

ConstOrVar · Accepted Answer · 2018-11-06 06:44:22Z

1

loadAllNotifications() .flatMapObservable { Observable.fromIterable(it) } .map { it.copy(isOpened = false) } .toList() .flatMapCompletable{ insertAll(it) }

answered Nov 6, 2018 at 6:44

ConstOrVar

2,0851 gold badge13 silver badges17 bronze badges

Sign up to request clarification or add additional context in comments.

1 Comment

liminal Over a year ago

Brilliant. Thanks very much!

Collectives™ on Stack Overflow

RxJava stream transformation

1 Answer 1

1 Comment

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

1 Comment

Related