com.bumptech.glide.util.ContentLengthInputStream#obtain ( )源码实例Demo

下面列出了com.bumptech.glide.util.ContentLengthInputStream#obtain ( ) 实例代码，或者点击链接到github查看源代码，也可以在右侧发表评论。

源代码1 项目： imsdk-android 文件： OkHttpStreamFetcher.java

@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;
}

源代码2 项目： NewFastFrame 文件： OkHttpStreamFetcher.java

@Override
public void loadData(@NonNull Priority priority, @NonNull DataCallback<? super InputStream> callback) {
    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 = null;
    call = client.newCall(request);
    try {
        response = call.execute();
        responseBody = response.body();
    } catch (IOException e) {
        e.printStackTrace();
        callback.onLoadFailed(new IOException("Request failed with code: "));
        return;
    }
        long contentLength = responseBody.contentLength();
        stream = ContentLengthInputStream.obtain(responseBody.byteStream(), contentLength);
        callback.onDataReady(stream);
}

源代码3 项目： TestChat 文件： OkHttpStreamFetcher.java

@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;
}

源代码4 项目： AndroidModulePattern 文件： OkHttpStreamFetcher.java

@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;
}

源代码5 项目： glide-support 文件： StethoHttpUrlFetcher.java

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;
	}
}

源代码6 项目： AndroidBase 文件： OkHttpStreamFetcher.java

@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;
}

源代码7 项目： android-tutorials-glide 文件： OkHttpStreamFetcher.java

@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;
}

源代码8 项目： hipda 文件： ImageStreamFetcher.java

@Override
public void loadData(Priority priority, DataCallback<? super InputStream> callback) {
    Request request = getRequest();
    try {
        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);
        callback.onDataReady(stream);
    } catch (Exception e) {
        callback.onLoadFailed(e);
    }
}

源代码9 项目： mollyim-android 文件： OkHttpStreamFetcher.java

@Override
public void loadData(@NonNull Priority priority, @NonNull DataCallback<? super InputStream> callback) {
  try {
    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);

    callback.onDataReady(stream);
  } catch (IOException e) {
    callback.onLoadFailed(e);
  }
}

源代码10 项目： giffun 文件： HttpUrlFetcher.java

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;
}

源代码11 项目： bcm-android 文件： OkHttpStreamFetcher.java

@Override
public void loadData(Priority priority, DataCallback<? super InputStream> callback) {
  try {
    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);

    callback.onDataReady(stream);
  } catch (IOException e) {
    callback.onLoadFailed(e);
  }
}

源代码12 项目： AndroidProject 文件： OkHttpFetcher.java

@Override
public void onResponse(@NonNull Call call, @NonNull Response response) {
    mResponseBody = response.body();
    if (response.isSuccessful()) {
        long contentLength = Preconditions.checkNotNull(mResponseBody).contentLength();
        mInputStream = ContentLengthInputStream.obtain(mResponseBody.byteStream(), contentLength);
        mDataCallback.onDataReady(mInputStream);
    } else {
        mDataCallback.onLoadFailed(new HttpException(response.message(), response.code()));
    }
}

源代码13 项目： FastAndroid 文件： OkHttpStreamFetcher.java

@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()));
    }
}

源代码14 项目： Aurora 文件： OkHttpStreamFetcher.java

@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()));
    }
}

源代码15 项目： MVVMArms 文件： OkHttpStreamFetcher.java

@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()));
    }
}

源代码16 项目： pandroid 文件： OkHttpStreamFetcher.java

@Override
public void onResponse(@NonNull Call call, @NonNull Response response) {
  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()));
  }
}

源代码17 项目： MVPArms 文件： OkHttpStreamFetcher.java

@Override
public void onResponse(@NonNull Call call, @NonNull Response response) {
    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()));
    }
}

方法所在类

com.bumptech.glide.util.ContentLengthInputStream