diff --git a/app/src/module_community/java/com/nnbc123/app/community/publish/presenter/PublishPresenter.java b/app/src/module_community/java/com/nnbc123/app/community/publish/presenter/PublishPresenter.java index bd82b28c8..eeeb6c62a 100644 --- a/app/src/module_community/java/com/nnbc123/app/community/publish/presenter/PublishPresenter.java +++ b/app/src/module_community/java/com/nnbc123/app/community/publish/presenter/PublishPresenter.java @@ -133,7 +133,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/nnbc123/core/file/FileModel.java b/core/src/main/java/com/nnbc123/core/file/FileModel.java index 70b1a9461..11a474205 100644 --- a/core/src/main/java/com/nnbc123/core/file/FileModel.java +++ b/core/src/main/java/com/nnbc123/core/file/FileModel.java @@ -14,6 +14,7 @@ import com.nnbc123.library.net.rxnet.RxNet; 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 { @@ -52,7 +53,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