Mercury-IM/Mercury-IM
Mercury-IM/Mercury-IM
1
0
Fork 0
mirror of https://codeberg.org/Mercury-IM/Mercury-IM synced 2024-06-18 09:34:52 +02:00
Code Issues Projects Releases Wiki Activity

Reformat

Browse source
This commit is contained in:
Paul Schaub 2019-12-22 02:58:58 +01:00
parent 4491df0dd3
commit 875321ed00
Signed by: vanitasvitae
GPG key ID: 62BEE9264BF17311
1 changed files with 7 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
data/src/main/java/org/mercury_im/messenger/data/repository/XmppGroupChatRepository.java
View file

@ -75,14 +75,13 @@ public class XmppGroupChatRepository
@Override
public Single<GroupChat> getOrCreateGroupChat(Account account, String roomAddress) {
return getGroupChatByRoomAddress(account, roomAddress)
.switchIfEmpty(
Single.just(new IGroupChat())
.map(chat -> {
chat.setAccount(account);
chat.setRoomAddress(roomAddress);
return chat;
})
.flatMap(this::insertGroupChat))
.switchIfEmpty(Single.just(new IGroupChat())
.map(chat -> {
chat.setAccount(account);
chat.setRoomAddress(roomAddress);
return chat;
})
.flatMap(this::insertGroupChat))
.subscribeOn(subscriberScheduler())
.observeOn(observerScheduler());
}