Java 类retrofit2.http.Streaming 实例源码

项目：GitHub 文件：BuiltInConverters.java

@Override
public Converter<ResponseBody, ?> responseBodyConverter(Type type, Annotation[] annotations,
    Retrofit retrofit) {
  if (type == ResponseBody.class) {
    return Utils.isAnnotationPresent(annotations, Streaming.class)
        ? StreamingResponseBodyConverter.INSTANCE
        : BufferingResponseBodyConverter.INSTANCE;
  }
  if (type == Void.class) {
    return VoidResponseBodyConverter.INSTANCE;
  }
  return null;
}

项目：GitHub 文件：BuiltInConverters.java

@Override
public Converter<ResponseBody, ?> responseBodyConverter(Type type, Annotation[] annotations,
    Retrofit retrofit) {
  if (type == ResponseBody.class) {
    return Utils.isAnnotationPresent(annotations, Streaming.class)
        ? StreamingResponseBodyConverter.INSTANCE
        : BufferingResponseBodyConverter.INSTANCE;
  }
  if (type == Void.class) {
    return VoidResponseBodyConverter.INSTANCE;
  }
  return null;
}

项目：EvolvingNetLib 文件：CCNetApiService.java

/**
 * 下载文件
 * @param url
 * @param headerMap
 * @param txtParamMap
 * @return
 */
@Streaming
@GET
Call<ResponseBody> executeDownload(
        @Url String url,
        @HeaderMap Map<String, String> headerMap,
        @QueryMap Map<String, String> txtParamMap
);

项目：JavaAyo 文件：BuiltInConverters.java

@Override
public Converter<ResponseBody, ?> responseBodyConverter(Type type, Annotation[] annotations,
    Retrofit retrofit) {
  if (type == ResponseBody.class) {
    if (Utils.isAnnotationPresent(annotations, Streaming.class)) {
      return StreamingResponseBodyConverter.INSTANCE;
    }
    return BufferingResponseBodyConverter.INSTANCE;
  }
  if (type == Void.class) {
    return VoidResponseBodyConverter.INSTANCE;
  }
  return null;
}

项目：retrofit2-download-adapter 文件：DownloadCallAdapterFactory.java

@Override
public CallAdapter<?> get(Type returnType, Annotation[] annotations, final Retrofit retrofit) {
    if (returnType != Download.Builder.class) {
        return null;
    }

    if (!Util.isAnnotationPresent(annotations, Streaming.class)) {
        throw new IllegalArgumentException("Download.Builder requires @Streaming.");
    }

    return new CallAdapter<Download.Builder>() {
        @Override
        public Type responseType() {
            return ResponseBody.class;
        }

        @SuppressWarnings("unchecked")
        @Override
        public <R> Download.Builder adapt(Call<R> call) {
            Download.Builder builder = new Download.Builder((Call<ResponseBody>) call);

            Executor callbackExecutor = retrofit.callbackExecutor();

            if (callbackExecutor != null) {
                builder.callbackExecutor(callbackExecutor);
            }

            return builder;
        }
    };
}

项目：ImitateZHRB 文件：ZHRBApi.java

@Streaming
@GET
Call<ResponseBody> downloadFile(@Url String fileUrl);

项目：GitHub 文件：DownloadApi.java

@GET
@Streaming
Flowable<Response<ResponseBody>> download(@Header("Range") String range,
                                          @Url String url);

项目：Clipcon-AndroidClient 文件：RetrofitInterface.java

/** download */
@Streaming
@Headers({ "User-Agent: androidProgram" })
@GET("DownloadServlet")
Call<ResponseBody> requestFileDataDownload(@QueryMap Map<String, String> parameters);

项目：TWStreaming 文件：ITwitterStreamingAPI.java

@Streaming
@POST("statuses/filter.json")
Observable<ResponseBody> getStreamingStatuses(@Query("track") String track, @Query("filter_level") String filterLevel);

项目：Bailan 文件：HttpDownService.java

@Streaming/*大文件需要加入这个判断，防止下载过程中写入到内存中*/
@GET
Observable<ResponseBody> download(@Header("RANGE") String start, @Url String url);

项目：RxRetrofit-tokean 文件：HttpDownService.java

@Streaming/*大文件需要加入这个判断，防止下载过程中写入到内存中*/
@GET
Observable<ResponseBody> download(@Header("RANGE") String start, @Url String url);

项目：TestChat 文件：HttpService.java

@Streaming/*大文件需要加入这个判断，防止下载过程中写入到内存中*/
@GET
Observable<ResponseBody> download(@Header("RANGE") String start, @Url String url);

项目：TestChat 文件：ApiService.java

@Streaming
@GET
Call<ResponseBody> download(@Url String url, @HeaderMap Map<String,String> headerMap);

项目：filestack-java 文件：CdnService.java

@GET("{handle}")
@Streaming
Call<ResponseBody> get(
    @Path("handle") String handle,
    @Query("policy") String policy,
    @Query("signature") String signature);

项目：filestack-java 文件：CdnService.java

@Streaming
@GET("{tasks}/{handle}")
Call<ResponseBody> transform(
    @Path("tasks") String tasks,
    @Path("handle") String handle);

项目：filestack-java 文件：CdnService.java

@Streaming
@GET("{key}/{tasks}/{url}")
Call<ResponseBody> transformExt(
    @Path("key") String key,
    @Path("tasks") String tasks,
    @Path("url") String url);

项目：XSnow 文件：ApiService.java

@Streaming
@GET()
Observable<ResponseBody> downFile(@Url() String url, @QueryMap Map<String, String> maps);

项目：JD-Test 文件：BaseApiService.java

@Streaming
@GET
Flowable<ResponseBody> downloadFile(@Url String fileUrl);

项目：RxEasyHttp 文件：ApiService.java

@Streaming
@GET
Observable<ResponseBody> downloadFile(@Url String fileUrl);

项目：DOUSalaries 文件：SalaryApiService.java

@Streaming
@GET
Call<ResponseBody> downloadDouFile(@Url String fileUrl);

项目：Auto.js 文件：DownloadApi.java

@GET
@Streaming
Observable<ResponseBody> download(@Url String url);

项目：Plamber-Android 文件：PlamberAPI.java

@Streaming
@GET
Call<ResponseBody> downloadFile(@Url String fileUrl);

项目：FastEc 文件：RestService.java

@Streaming
@GET
Call<ResponseBody> download(@Url String url, @QueryMap Map<String, Object> params);