|
@@ -39,8 +39,6 @@ import com.nextcloud.talk.utils.UserIdUtils;
|
|
import com.nextcloud.talk.utils.database.user.CapabilitiesUtilNew;
|
|
import com.nextcloud.talk.utils.database.user.CapabilitiesUtilNew;
|
|
import com.yarolegovich.mp.io.StorageModule;
|
|
import com.yarolegovich.mp.io.StorageModule;
|
|
|
|
|
|
-import org.jetbrains.annotations.NotNull;
|
|
|
|
-
|
|
|
|
import java.util.Set;
|
|
import java.util.Set;
|
|
|
|
|
|
import javax.inject.Inject;
|
|
import javax.inject.Inject;
|
|
@@ -48,6 +46,7 @@ import javax.inject.Inject;
|
|
import autodagger.AutoInjector;
|
|
import autodagger.AutoInjector;
|
|
import io.reactivex.Observer;
|
|
import io.reactivex.Observer;
|
|
import io.reactivex.android.schedulers.AndroidSchedulers;
|
|
import io.reactivex.android.schedulers.AndroidSchedulers;
|
|
|
|
+import io.reactivex.annotations.NonNull;
|
|
import io.reactivex.disposables.Disposable;
|
|
import io.reactivex.disposables.Disposable;
|
|
import io.reactivex.schedulers.Schedulers;
|
|
import io.reactivex.schedulers.Schedulers;
|
|
|
|
|
|
@@ -91,17 +90,17 @@ public class DatabaseStorageModule implements StorageModule {
|
|
.observeOn(AndroidSchedulers.mainThread())
|
|
.observeOn(AndroidSchedulers.mainThread())
|
|
.subscribe(new Observer<GenericOverall>() {
|
|
.subscribe(new Observer<GenericOverall>() {
|
|
@Override
|
|
@Override
|
|
- public void onSubscribe(@NotNull Disposable d) {
|
|
|
|
|
|
+ public void onSubscribe(@NonNull Disposable d) {
|
|
// unused atm
|
|
// unused atm
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|
|
- public void onNext(@NotNull GenericOverall genericOverall) {
|
|
|
|
|
|
+ public void onNext(@NonNull GenericOverall genericOverall) {
|
|
Log.d(TAG, "Toggled notification calls");
|
|
Log.d(TAG, "Toggled notification calls");
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|
|
- public void onError(@NotNull Throwable e) {
|
|
|
|
|
|
+ public void onError(@NonNull Throwable e) {
|
|
Log.e(TAG, "Error when trying to toggle notification calls", e);
|
|
Log.e(TAG, "Error when trying to toggle notification calls", e);
|
|
}
|
|
}
|
|
|
|
|
|
@@ -144,17 +143,17 @@ public class DatabaseStorageModule implements StorageModule {
|
|
.observeOn(AndroidSchedulers.mainThread())
|
|
.observeOn(AndroidSchedulers.mainThread())
|
|
.subscribe(new Observer<GenericOverall>() {
|
|
.subscribe(new Observer<GenericOverall>() {
|
|
@Override
|
|
@Override
|
|
- public void onSubscribe(@NotNull Disposable d) {
|
|
|
|
|
|
+ public void onSubscribe(@NonNull Disposable d) {
|
|
// unused atm
|
|
// unused atm
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|
|
- public void onNext(@NotNull GenericOverall genericOverall) {
|
|
|
|
|
|
+ public void onNext(@NonNull GenericOverall genericOverall) {
|
|
messageExpiration = valueInt;
|
|
messageExpiration = valueInt;
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|
|
- public void onError(@NotNull Throwable e) {
|
|
|
|
|
|
+ public void onError(@NonNull Throwable e) {
|
|
Log.e(TAG, "Error when trying to set message expiration", e);
|
|
Log.e(TAG, "Error when trying to set message expiration", e);
|
|
}
|
|
}
|
|
|
|
|