Further tweaks for party page

This commit is contained in:
Phillip Thelen 2019-10-24 17:43:23 +02:00
parent ea9de8e5e6
commit 0d4528de67
4 changed files with 14 additions and 27 deletions

View file

@ -125,13 +125,7 @@ class SocialRepositoryImpl(localRepository: SocialLocalRepository, apiClient: Ap
override fun retrieveGroup(id: String): Flowable<Group> {
return Flowable.zip(apiClient.getGroup(id).doOnNext { localRepository.save(it) }, retrieveGroupChat(id)
.map { message ->
message.forEach {
it.groupId = id
}
message
}
.doOnSuccess { localRepository.save(it) }.toFlowable(),
.toFlowable(),
BiFunction<Group, List<ChatMessage>, Group> { group, _ ->
group
}

View file

@ -93,8 +93,6 @@ class ChatFragment : BaseFragment() {
}
})
refresh()
viewModel?.getChatMessages()?.subscribe(Consumer<RealmResults<ChatMessage>> { this.setChatMessages(it) }, RxErrorHandler.handleEmptyError())?.let { compositeSubscription.add(it) }
communityGuidelinesReviewView.setOnClickListener {

View file

@ -191,7 +191,6 @@ class PartyDetailFragment : BaseFragment() {
}
private fun updateMembersList(members: RealmResults<Member>?) {
membersWrapper?.removeAllViews()
val leaderID = viewModel?.leaderID
members?.forEachIndexed { index, member ->
val memberView = (if (membersWrapper?.childCount ?: 0 > index) {

View file

@ -58,26 +58,22 @@ class PartyFragment : BaseMainFragment() {
viewModel.loadPartyID()
compositeSubscription.add(userRepository.getUser()
.map {
it.hasParty()
}
compositeSubscription.add(viewModel.groupIDFlowable.map { it.value != null }
.distinctUntilChanged()
.subscribe(Consumer {
val fragment = firstFragment
if (fragment != null) {
childFragmentManager.beginTransaction().remove(fragment).commit()
}
viewPager?.adapter?.notifyDataSetChanged()
val fragment = firstFragment
if (fragment != null) {
childFragmentManager.beginTransaction().remove(fragment).commit()
}
viewPager?.adapter?.notifyDataSetChanged()
if (it) {
viewModel.retrieveGroup {}
tabLayout?.visibility = View.VISIBLE
} else {
tabLayout?.visibility = View.GONE
}
}, RxErrorHandler.handleEmptyError()))
if (it) {
viewModel.retrieveGroup {}
tabLayout?.visibility = View.VISIBLE
} else {
tabLayout?.visibility = View.GONE
}
}, RxErrorHandler.handleEmptyError()))
viewPager?.currentItem = 0