|
@@ -53,13 +53,13 @@ class LeaveConversationWorker(context: Context, workerParams: WorkerParameters)
|
|
val apiVersion = getConversationApiVersion(currentUser, intArrayOf(ApiUtils.API_V4, 1))
|
|
val apiVersion = getConversationApiVersion(currentUser, intArrayOf(ApiUtils.API_V4, 1))
|
|
|
|
|
|
ncApi.removeSelfFromRoom(
|
|
ncApi.removeSelfFromRoom(
|
|
- credentials, getUrlForParticipantsSelf(apiVersion, currentUser.baseUrl, conversationToken)
|
|
|
|
|
|
+ credentials,
|
|
|
|
+ getUrlForParticipantsSelf(apiVersion, currentUser.baseUrl, conversationToken)
|
|
)
|
|
)
|
|
.subscribeOn(Schedulers.io())
|
|
.subscribeOn(Schedulers.io())
|
|
.observeOn(AndroidSchedulers.mainThread())
|
|
.observeOn(AndroidSchedulers.mainThread())
|
|
.subscribe(object : Observer<GenericOverall?> {
|
|
.subscribe(object : Observer<GenericOverall?> {
|
|
override fun onSubscribe(d: Disposable) {
|
|
override fun onSubscribe(d: Disposable) {
|
|
-
|
|
|
|
}
|
|
}
|
|
|
|
|
|
override fun onNext(p0: GenericOverall) {
|
|
override fun onNext(p0: GenericOverall) {
|