- android - RelativeLayout 背景可绘制重叠内容
- android - 如何链接 cpufeatures lib 以获取 native android 库?
- java - OnItemClickListener 不起作用,但 OnLongItemClickListener 在自定义 ListView 中起作用
- java - Android 文件转字符串
在我们的应用程序中,我使用此代码下载图像文件。我需要在 UI 上显示下载进度(下载字节数百分比)。如何在此代码中获取下载进度?我搜索了解决方案,但仍然无法自行解决。
Observable<String> downloadObservable = Observable.create(
sub -> {
Request request = new Request.Builder()
.url(media.getMediaUrl())
.build();
Response response = null;
try {
response = http_client.newCall(request).execute();
if (response.isSuccessful()) {
Log.d(TAG, "response.isSuccessful()");
String mimeType = MimeTypeMap.getFileExtensionFromUrl(media.getMediaUrl());
File file = new File(helper.getTmpFolder() + "/" + helper.generateUniqueName() + "test." + mimeType);
BufferedSink sink = Okio.buffer(Okio.sink(file));
sink.writeAll(response.body().source());
sink.close();
sub.onNext(response.toString());
sub.onCompleted();
} else {
sub.onError(new IOException());
}
} catch (IOException e) {
e.printStackTrace();
}
}
);
Subscriber<String> mySubscriber = new Subscriber<String>() {
@Override
public void onNext(String responseString) {
Log.d(TAG, "works: " + responseString);
}
};
downloadObservable
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(mySubscriber);
最佳答案
这是我用来显示进度的方法。
Observable<String> downloadObservable = Observable.create(
sub -> {
InputStream input = null;
OutputStream output = null;
try {
Response response = http_client.newCall(request).execute();
if (response.isSuccessful()) {
input = response.body().byteStream();
long tlength= response.body().contentLength();
output = new FileOutputStream("/pathtofile");
byte data[] = new byte[1024];
sub.onNext("0%");
long total = 0;
int count;
while ((count = input.read(data)) != -1) {
total += count;
sub.onNext(String.valueOf(total*100/tlength) + "%");
output.write(data, 0, count);
}
output.flush();
output.close();
input.close();
}
} catch(IOException e){
sub.onError(e);
} finally {
if (input != null){
try {
input.close();
}catch(IOException ioe){}
}
if (out != null){
try{
output.close();
}catch (IOException e){}
}
}
sub.onCompleted();
}
);
并使用具有完整抽象方法的Subscriber。
Subscriber<String> mySubscriber = new Subscriber<String>() {
@Override
public void onCompleted() {
// hide progress bar
}
@Override
public void onError(Throwable e) {
// hide progress bar
}
@Override
public void onNext(String percentProgress) {
// show percentage progress
}
};
关于android - 在 Android 中使用 RxJava、OkHttp 和 Okio 下载进度,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/29958881/
我有一个运行良好的应用程序,但有时当我向我的程序添加一些类和代码时,我的应用程序崩溃了。在我的 logcat 错误是这样的: 8871-8929/com.example.first E/Androi
在使用 Android Studio 运行我的代码时,它会生成此错误: Warning: Conflict with dependency 'com.squareup.okio: okio'. Res
我已经包含 okhttp3 并在低于 LOLLIPOP (api 21) 的安卓版本中测试了 PATCH 和 DELETE 方法。我没有包括 Okio,它运行良好。但是,在 okhttp site他们
我开始收到有关 的错误 **InvalidPackage: Package not included in Android** ../../../../../../../.gradle/caches/
我正在使用 OkHttp(首先是原始版本,然后我升级到 OkHttp3),我的应用程序的一些用户报告说,当应用程序未运行时,电池生命周期会显着下降。 我运行了一个分析器,结果是这样的: 如您所见,Ok
我的团队正受此困扰issue使用 slack 集成来上传文件,因此根据该问题中的评论,我想限制我们的 Kotlin 实现中的请求。 我正在尝试集成 Okio Throttler在 OkHttp 拦截器
i am getting this error when after integrating the OverAir sdks in Gradle and i dont know which one
大家好,我正在从 Android 设备读取原始音频,我想使用 Okio 将其写入文件中像这样: BufferedSink sink = Okio.buffer(Okio.sink(file)); 我有
我的系统需要使用 WAV 文件数组的字节创建单个 WAV 文件。目前它使用 Okio 在缓冲区上读取和写入数据,然后将数据写入最终文件。 我正在关注此文档和此堆栈溢出问题: http://tiny.s
已经在给定的解决方案下实现,但没有一个能正常工作,仍然面临下面列出的警告。 Warning: okio.DeflaterSink: can't find referenced class org.co
我正在尝试将此工作文件下载代码转换为 Reactive。但是由于我对 RxJava 知之甚少,卡住了。你能帮我把它变成 Reactive 吗? public void downloadFile(Mes
使用 OkHttp Websocket 时 listener使用 ByteString 向应用程序提供二进制有效负载。我想将这些字节输入到一些需要 okio.Source (在本例中为 GzipSou
我注意到 fabric 中有这样的异常,这种异常很少发生,但每次构建时,每周 2-3 个用户(约 500 DAU)会发生 3-5 次崩溃我没有找到有关此类崩溃的任何信息,有人知道是什么原因造成的吗?
我正在尝试使用 OkHttp 下载文件并使用 Okio 写入磁盘。我还为这个过程创建了一个 rx observable。它正在运行,但是它明显比我以前使用的(Koush 的 Ion 库)慢。 下面是我
我试图找出为什么 OkHttp 使用 Okio 而不是 BufferedInputStream 和 BufferedOutputStream 来缓冲数据。我用下面的代码来验证: private Str
我有一个应用程序可以从网络上下载内容。音乐、视频、pdf……就像一个下载管理器。 但现在每次下载内容时都会崩溃: E/LVN/advanced_memory_manager.c: ----------
在我们的应用程序中,我使用此代码下载图像文件。我需要在 UI 上显示下载进度(下载字节数百分比)。如何在此代码中获取下载进度?我搜索了解决方案,但仍然无法自行解决。 Observable downlo
我正在集成 Outlook API 并进行 HTTP 调用,我正在使用 改造版本 2.3.0 和 okHttp3 版本 3.9.1。 但是,当我进行 HTTP 调用时,例如: // Create a
问题是标题所说的。它只发生在有时和一些电话上。听说是我抓到的日志。 java.lang.IllegalStateException closed okio.RealBufferedSink.write
我遇到了依赖项问题,在某个地方我对 okio.Buffer$2 和可能对 okio.AsyncTimeout 有双重依赖(它在尝试解决问题时突然出现,但我在隔离问题时遇到了麻烦)。这是我的依赖项。 i
我是一名优秀的程序员,十分优秀!