本文整理汇总了Java中com.bumptech.glide.util.ContentLengthInputStream类的典型用法代码示例。如果您正苦于以下问题:Java ContentLengthInputStream类的具体用法?Java ContentLengthInputStream怎么用?Java ContentLengthInputStream使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
ContentLengthInputStream类属于com.bumptech.glide.util包,在下文中一共展示了ContentLengthInputStream类的10个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: loadData
import com.bumptech.glide.util.ContentLengthInputStream; //导入依赖的package包/类
@Override
public InputStream loadData(Priority priority) throws Exception {
Request.Builder requestBuilder = new Request.Builder().url(url.toStringUrl());
for (Map.Entry<String, String> headerEntry : url.getHeaders().entrySet()) {
String key = headerEntry.getKey();
requestBuilder.addHeader(key, headerEntry.getValue());
}
Request request = requestBuilder.build();
Response response;
call = client.newCall(request);
response = call.execute();
responseBody = response.body();
if (!response.isSuccessful()) {
throw new IOException("Request failed with code: " + response.code());
}
long contentLength = responseBody.contentLength();
stream = ContentLengthInputStream.obtain(responseBody.byteStream(), contentLength);
return stream;
}
开发者ID:RockyQu,项目名称:MVVMFrames,代码行数:23,代码来源:OkHttpStreamFetcher.java
示例2: loadData
import com.bumptech.glide.util.ContentLengthInputStream; //导入依赖的package包/类
@Override
public InputStream loadData(Priority priority) throws Exception {
Request.Builder requestBuilder = new Request.Builder()
.url(url.toStringUrl());
for (Map.Entry<String, String> headerEntry : url.getHeaders().entrySet()) {
String key = headerEntry.getKey();
requestBuilder.addHeader(key, headerEntry.getValue());
}
Request request = requestBuilder.build();
Response response = client.newCall(request).execute();
responseBody = response.body();
if (!response.isSuccessful()) {
throw new IOException("Request failed with code: " + response.code());
}
long contentLength = responseBody.contentLength();
stream = ContentLengthInputStream.obtain(responseBody.byteStream(), contentLength);
return stream;
}
开发者ID:XecureIT,项目名称:PeSanKita-android,代码行数:24,代码来源:OkHttpStreamFetcher.java
示例3: loadData
import com.bumptech.glide.util.ContentLengthInputStream; //导入依赖的package包/类
@Override
public InputStream loadData(Priority priority) throws Exception {
Request.Builder requestBuilder = new Request.Builder()
.url(url.toStringUrl());
for (Map.Entry<String, String> headerEntry : url.getHeaders().entrySet()) {
String key = headerEntry.getKey();
requestBuilder.addHeader(key, headerEntry.getValue());
}
Request request = requestBuilder.build();
Response response = client.newCall(request).execute();
responseBody = response.body();
if (!response.isSuccessful()) {
throw new IOException("Request failed with code: " + response.code());
}
long contentLength = responseBody.contentLength();
stream = ContentLengthInputStream.obtain(responseBody.byteStream(), contentLength);
return stream;
}
开发者ID:HelloChenJinJun,项目名称:TestChat,代码行数:23,代码来源:OkHttpStreamFetcher.java
示例4: getStreamForSuccessfulRequest
import com.bumptech.glide.util.ContentLengthInputStream; //导入依赖的package包/类
private InputStream getStreamForSuccessfulRequest(HttpURLConnection urlConnection) throws IOException {
try {
InputStream responseStream = stethoManager.interpretResponseStream(urlConnection.getInputStream());
if (TextUtils.isEmpty(urlConnection.getContentEncoding())) {
int contentLength = urlConnection.getContentLength();
stream = ContentLengthInputStream.obtain(responseStream, contentLength);
} else {
if (Log.isLoggable(TAG, Log.DEBUG)) {
Log.d(TAG, "Got non empty content encoding: " + urlConnection.getContentEncoding());
}
stream = responseStream;
}
return stream;
} catch (IOException ex) {
stethoManager.httpExchangeFailed(ex);
throw ex;
}
}
开发者ID:TWiStErRob,项目名称:glide-support,代码行数:19,代码来源:StethoHttpUrlFetcher.java
示例5: loadData
import com.bumptech.glide.util.ContentLengthInputStream; //导入依赖的package包/类
@Override
public InputStream loadData(Priority priority) throws Exception {
Request.Builder requestBuilder = new Request.Builder().url(url.toStringUrl());
for (Map.Entry<String, String> headerEntry : url.getHeaders().entrySet()) {
String key = headerEntry.getKey();
requestBuilder.addHeader(key, headerEntry.getValue());
}
Request request = requestBuilder.build();
Response response;
call = client.newCall(request);
response = call.execute();
responseBody = response.body();
if (!response.isSuccessful()) {
throw new IOException("Request failed with code: " + response.code());
}
long contentLength = responseBody.contentLength();
stream = ContentLengthInputStream.obtain(responseBody.byteStream(), contentLength);
return stream;
}
开发者ID:lujianzhao,项目名称:AndroidBase,代码行数:23,代码来源:OkHttpStreamFetcher.java
示例6: getStreamForSuccessfulRequest
import com.bumptech.glide.util.ContentLengthInputStream; //导入依赖的package包/类
private InputStream getStreamForSuccessfulRequest(HttpURLConnection urlConnection)
throws IOException {
if (TextUtils.isEmpty(urlConnection.getContentEncoding())) {
int contentLength = urlConnection.getContentLength();
stream = ContentLengthInputStream.obtain(urlConnection.getInputStream(), contentLength);
} else {
if (Log.isLoggable(TAG, Log.DEBUG)) {
Log.d(TAG, "Got non empty content encoding: " + urlConnection.getContentEncoding());
}
stream = urlConnection.getInputStream();
}
return stream;
}
开发者ID:weiwenqiang,项目名称:GitHub,代码行数:14,代码来源:HttpUrlFetcher.java
示例7: onResponse
import com.bumptech.glide.util.ContentLengthInputStream; //导入依赖的package包/类
@Override
public void onResponse(@NonNull Call call, @NonNull Response response) throws IOException {
responseBody = response.body();
if (response.isSuccessful()) {
long contentLength = Preconditions.checkNotNull(responseBody).contentLength();
stream = ContentLengthInputStream.obtain(responseBody.byteStream(), contentLength);
callback.onDataReady(stream);
} else {
callback.onLoadFailed(new HttpException(response.message(), response.code()));
}
}
开发者ID:weiwenqiang,项目名称:GitHub,代码行数:12,代码来源:OkHttpStreamFetcher.java
示例8: onResponse
import com.bumptech.glide.util.ContentLengthInputStream; //导入依赖的package包/类
@Override
public void onResponse(Call call, Response response) throws IOException {
responseBody = response.body();
if (response.isSuccessful()) {
long contentLength = responseBody.contentLength();
stream = ContentLengthInputStream.obtain(responseBody.byteStream(), contentLength);
callback.onDataReady(stream);
} else {
callback.onLoadFailed(new HttpException(response.message(), response.code()));
}
}
开发者ID:Superingxz,项目名称:MoligyMvpArms,代码行数:12,代码来源:OkHttpStreamFetcher.java
示例9: onResponse
import com.bumptech.glide.util.ContentLengthInputStream; //导入依赖的package包/类
@Override
public void onResponse(@NonNull Call call, @NonNull Response response) throws IOException {
responseBody = response.body();
if (response.isSuccessful()) {
long contentLength = responseBody.contentLength();
stream = ContentLengthInputStream.obtain(responseBody.byteStream(), contentLength);
callback.onDataReady(stream);
} else {
callback.onLoadFailed(new HttpException(response.message(), response.code()));
}
}
开发者ID:xiaobailong24,项目名称:MVVMArms,代码行数:12,代码来源:OkHttpStreamFetcher.java
示例10: loadData
import com.bumptech.glide.util.ContentLengthInputStream; //导入依赖的package包/类
@Override
public InputStream loadData(Priority priority) throws Exception {
Request request = getRequest();
Response response = client.newCall(request).execute();
responseBody = response.body();
if (!response.isSuccessful()) {
throw new IOException(OkHttpHelper.ERROR_CODE_PREFIX + response.code());
}
long contentLength = responseBody.contentLength();
stream = ContentLengthInputStream.obtain(responseBody.byteStream(), contentLength);
return stream;
}
开发者ID:GreenSkinMonster,项目名称:hipda,代码行数:15,代码来源:ImageStreamFetcher.java
注:本文中的com.bumptech.glide.util.ContentLengthInputStream类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论