diff --git a/app/src/module_community/java/com/yizhuan/erban/community/publish/presenter/PublishPresenter.java b/app/src/module_community/java/com/yizhuan/erban/community/publish/presenter/PublishPresenter.java index dca3d9237..cd5d2007f 100644 --- a/app/src/module_community/java/com/yizhuan/erban/community/publish/presenter/PublishPresenter.java +++ b/app/src/module_community/java/com/yizhuan/erban/community/publish/presenter/PublishPresenter.java @@ -135,7 +135,6 @@ public class PublishPresenter extends BaseMvpPresenter { .flatMap((Function>) path -> FileModel.get().uploadFile(path)) .compose(bindUntilEvent(PresenterEvent.DESTROY)) - .observeOn(AndroidSchedulers.mainThread()) .subscribe(new DontWarnObserver() { @Override public void acceptThrowable(String url, Throwable throwable) { diff --git a/core/src/main/java/com/yizhuan/xchat_android_core/file/FileModel.java b/core/src/main/java/com/yizhuan/xchat_android_core/file/FileModel.java index c9261bfb2..21a4513a6 100644 --- a/core/src/main/java/com/yizhuan/xchat_android_core/file/FileModel.java +++ b/core/src/main/java/com/yizhuan/xchat_android_core/file/FileModel.java @@ -18,6 +18,7 @@ import java.io.File; import java.util.UUID; import io.reactivex.Single; +import io.reactivex.android.schedulers.AndroidSchedulers; import retrofit2.http.GET; public class FileModel extends BaseModel implements IFileModel { @@ -57,7 +58,8 @@ public class FileModel extends BaseModel implements IFileModel { } File finalFile = file; String outName = UUID.randomUUID().toString() + PathUtils.INSTANCE.getSuffixType(finalFile.getName()); - return getCosToken().flatMap(token -> CosClient.INSTANCE.upload(AppUtils.getApp(), finalFile, outName, token).map(cosXmlResult -> cosXmlResult.accessUrl)); + return getCosToken().flatMap(token -> CosClient.INSTANCE.upload(AppUtils.getApp(), finalFile, outName, token).map(cosXmlResult -> cosXmlResult.accessUrl)) + .observeOn(AndroidSchedulers.mainThread()); } @Override