Commit 605c9a26 authored by Vladislav's avatar Vladislav

update user

parent 936097b5
...@@ -101,6 +101,7 @@ class SubscriptionRepository @Inject constructor( ...@@ -101,6 +101,7 @@ class SubscriptionRepository @Inject constructor(
,topicName = topic ,topicName = topic
,topicId = topic_id) ,topicId = topic_id)
.flatMap { saveSubscribtions(user,it.subscriptions?: arrayListOf()) } .flatMap { saveSubscribtions(user,it.subscriptions?: arrayListOf()) }
.doOnNext { db.refreshUser(user) }
override fun unSubscribeTopicResult( override fun unSubscribeTopicResult(
user:UserEntity, user:UserEntity,
...@@ -115,6 +116,7 @@ class SubscriptionRepository @Inject constructor( ...@@ -115,6 +116,7 @@ class SubscriptionRepository @Inject constructor(
,topicName = topic ,topicName = topic
,topicId = topic_id) ,topicId = topic_id)
.flatMap { saveSubscribtions(user,it.subscriptions?: arrayListOf()) } .flatMap { saveSubscribtions(user,it.subscriptions?: arrayListOf()) }
.doOnNext { db.refreshUser(user) }
override fun subscribeTopic( override fun subscribeTopic(
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment