com.squareup.okhttp.Call.enqueue()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(9.7k)|赞(0)|评价(0)|浏览(344)

本文整理了Java中com.squareup.okhttp.Call.enqueue()方法的一些代码示例，展示了Call.enqueue()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Call.enqueue()方法的具体详情如下：
包路径：com.squareup.okhttp.Call
类名称：Call
方法名：enqueue

Call.enqueue介绍

暂无

代码示例

代码示例来源：origin: xinghongfei/LookLook

  1. private void deliveryResult(final ResultCallback callback, Request request) {
  2.   mOkHttpClient.newCall(request).enqueue(new Callback() {
  3.     @Override
  4.     public void onFailure(Request request, final IOException e) {
  5.       sendFailCallback(callback, e);
  6.     }
  7.     @Override
  8.     public void onResponse(Response response) throws IOException {
  9.       try {
  10.         String str = response.body().string();
  11.         if (callback.mType == String.class) {
  12.           sendSuccessCallBack(callback, str);
  13.         } else {
  14.           Object object = JsonUtils.deserialize(str, callback.mType);
  15.           sendSuccessCallBack(callback, object);
  16.         }
  17.       } catch (final Exception e) {
  18.         sendFailCallback(callback, e);
  19.       }
  20.     }
  21.   });
  22. }

代码示例来源：origin: bumptech/glide

  1. @Override
  2. public void loadData(@NonNull Priority priority,
  3.   @NonNull final DataCallback<? super InputStream> callback) {
  4.  Request.Builder requestBuilder = new Request.Builder().url(url.toStringUrl());
  5.  for (Map.Entry<String, String> headerEntry : url.getHeaders().entrySet()) {
  6.   String key = headerEntry.getKey();
  7.   requestBuilder.addHeader(key, headerEntry.getValue());
  8.  }
  9.  Request request = requestBuilder.build();
  10.  client.newCall(request).enqueue(new com.squareup.okhttp.Callback() {
  11.   @Override
  12.   public void onFailure(Request request, IOException e) {
  13.    if (Log.isLoggable(TAG, Log.DEBUG)) {
  14.     Log.d(TAG, "OkHttp failed to obtain result", e);
  15.    }
  16.    callback.onLoadFailed(e);
  17.   }
  18.   @Override
  19.   public void onResponse(Response response) throws IOException {
  20.    responseBody = response.body();
  21.    if (response.isSuccessful()) {
  22.     long contentLength = responseBody.contentLength();
  23.     stream = ContentLengthInputStream.obtain(responseBody.byteStream(), contentLength);
  24.     callback.onDataReady(stream);
  25.    } else {
  26.     callback.onLoadFailed(new HttpException(response.message(), response.code()));
  27.    }
  28.   }
  29.  });
  30. }

代码示例来源：origin: commonsguy/cw-omnibus

  1. @Override
  2. public void onViewCreated(View view,
  3.              Bundle savedInstanceState) {
  4.  super.onViewCreated(view, savedInstanceState);
  5.  Request request=new Request.Builder()
  6.   .url(URL_BACKUPS)
  7.   .build();
  8.  BackupService.OKHTTP_CLIENT.newCall(request).enqueue(this);
  9. }

代码示例来源：origin: spotify/apollo

  1. finalClient.newCall(request).enqueue(TransformingCallback.create(result));

代码示例来源：origin: jiangqqlmj/FastDev4Android

  1. .url("http://www.baidu.com")
  2.     .build();
  3. client.newCall(request).enqueue(new Callback() {
  4.   @Override
  5.   public void onFailure(Request request, IOException e) {

代码示例来源：origin: cn-ljb/rxjava_for_android

  1. /**
  2.  * 异步CallBack模式
  3.  *
  4.  * @param request
  5.  * @param responseCallback
  6.  */
  7. public void enqueue(Request request, Callback responseCallback) {
  8.   mOkHttpClient.newCall(request).enqueue(responseCallback);
  9. }

代码示例来源：origin: liuling07/SimpleNews

  1. private void deliveryResult(final ResultCallback callback, Request request) {
  2.   mOkHttpClient.newCall(request).enqueue(new Callback() {
  3.     @Override
  4.     public void onFailure(Request request, final IOException e) {
  5.       sendFailCallback(callback, e);
  6.     }
  7.     @Override
  8.     public void onResponse(Response response) throws IOException {
  9.       try {
  10.         String str = response.body().string();
  11.         if (callback.mType == String.class) {
  12.           sendSuccessCallBack(callback, str);
  13.         } else {
  14.           Object object = JsonUtils.deserialize(str, callback.mType);
  15.           sendSuccessCallBack(callback, object);
  16.         }
  17.       } catch (final Exception e) {
  18.         LogUtils.e(TAG, "convert json failure", e);
  19.         sendFailCallback(callback, e);
  20.       }
  21.     }
  22.   });
  23. }

代码示例来源：origin: survivingwithandroid/Surviving-with-android

  1. .build();
  2. client.newCall(req).enqueue(new Callback() {
  3.   @Override
  4.   public void onFailure(Request request, IOException e) {

代码示例来源：origin: apache/servicemix-bundles

  1. public OkHttpListenableFuture(Call call) {
  2.   this.call = call;
  3.   this.call.enqueue(new Callback() {
  4.     @Override
  5.     public void onResponse(Response response) {
  6.       set(new OkHttpClientHttpResponse(response));
  7.     }
  8.     @Override
  9.     public void onFailure(Request request, IOException ex) {
  10.       setException(ex);
  11.     }
  12.   });
  13. }

代码示例来源：origin: liferay/liferay-mobile-sdk

  1. protected void sendAsync(Call call, final Callback callback) {
  2.   call.enqueue(new com.squareup.okhttp.Callback() {
  3.     @Override
  4.     public void onFailure(
  5.       com.squareup.okhttp.Request request, IOException ioe) {
  6.       callback.doFailure(ioe);
  7.     }
  8.     @Override
  9.     public void onResponse(com.squareup.okhttp.Response response)
  10.       throws IOException {
  11.       callback.inBackground(new Response(response));
  12.     }
  13.   });
  14. }

代码示例来源：origin: fire3/sailorcast

  1. public static void asyncGet(Request request, Callback callback) {
  2.   Log.d("fire3", "async request Url: " + request.urlString());
  3.   SailorCast.getHttpClient().newCall(request).enqueue(callback);
  4. }

代码示例来源：origin: fstab/http2-examples

  1. public static void main(String[] args) throws Exception {
  2.   OkHttpClient client = getUnsafeOkHttpClient();
  3.   Request request = new Request.Builder()
  4.       .url("https://localhost:8443") // The Http2Server should be running here.
  5.       .build();
  6.   long startTime = System.nanoTime();
  7.   for (int i=0; i<3; i++) {
  8.     Thread.sleep(1000); // http://stackoverflow.com/questions/32625035/when-using-http2-in-okhttp-why-multi-requests-to-the-same-host-didnt-use-just
  9.     client.newCall(request).enqueue(new Callback() {
  10.       public void onFailure(Request request, IOException e) {
  11.         e.printStackTrace();
  12.       }
  13.       public void onResponse(Response response) throws IOException {
  14.         long duration = TimeUnit.NANOSECONDS.toSeconds(System.nanoTime() - startTime);
  15.         System.out.println("After " + duration + " seconds: " + response.body().string());
  16.       }
  17.     });
  18.   }
  19. }

代码示例来源：origin: florent37/TutosAndroidFrance

  1. public void get(){
  2.   //get Request
  3.   Request myGetRequest = new Request.Builder()
  4.       .url("https://api.github.com/users/florent37")
  5.       .build();
  6.   okHttpClient.newCall(myGetRequest).enqueue(new Callback() {
  7.     @Override
  8.     public void onFailure(Request request, IOException e) {
  9.     }
  10.     @Override
  11.     public void onResponse(Response response) throws IOException {
  12.       //le retour est effectué dans un thread différent
  13.       final String text = response.body().string();
  14.       final int statusCode = response.code();
  15.       runOnUiThread(new Runnable() {
  16.         @Override
  17.         public void run() {
  18.           textView.setText(text);
  19.         }
  20.       });
  21.     }
  22.   });
  23. }

代码示例来源：origin: cyforever123/ElectronicbrandProject

  1. /**
  2.  * 异步Get请求 具体实现
  3.  *
  4.  * @param url             请求url
  5.  * @param iTRequestResult 请求回调
  6.  * @param clazz           Class<T>
  7.  * @param params          请求参数
  8.  * @param <T>             泛型模板
  9.  */
  10. public <T> void requestAsyncGetEnqueue(String url, ITRequestResult<T> iTRequestResult, Class<T> clazz, Param... params) {
  11.   String constructUrl = constructUrl(url, params);
  12.   Request request = new Request.Builder()
  13.       .get()
  14.       .url(constructUrl)
  15.       .build();
  16.   mOkHttpClient.newCall(request).enqueue(new TRequestCallBack(iTRequestResult, clazz));
  17. }

代码示例来源：origin: cyforever123/ElectronicbrandProject

  1. /**
  2.  * 异步DELETE请求  具体实现
  3.  *
  4.  * @param url             请求url
  5.  * @param iTRequestResult 请求回调
  6.  * @param clazz           Class<T>
  7.  * @param params          请求参数
  8.  * @param <T>             泛型模板
  9.  */
  10. public <T> void requestAsyncDelete(String url, ITRequestResult<T> iTRequestResult, Class<T> clazz, Param... params) {
  11.   String finalUrl = constructUrl(url, params);
  12.   Request request = new Request.Builder()
  13.       .delete()
  14.       .url(finalUrl)
  15.       .build();
  16.   mOkHttpClient.newCall(request).enqueue(new TRequestCallBack(iTRequestResult, clazz));
  17. }
  18. /*********************************************************** 文件请求*********************************************************/

代码示例来源：origin: liferay/liferay-mobile-sdk

  1. public static void signIn(
  2.     Session session, CookieCallback callback,
  3.     Authenticator authenticator) {
  4.   try {
  5.     CookieSignIn cookieSignIn = new CookieSignIn(
  6.         session);
  7.     Call call = cookieSignIn.signIn();
  8.     Callback requestCallback = getCallback(
  9.       session.getServer(), callback, cookieSignIn.cookieManager,
  10.       getCookieAuthentication(session.getAuthentication()));
  11.     call.enqueue(requestCallback);
  12.   }
  13.   catch (Exception e) {
  14.     callback.onFailure(e);
  15.   }
  16. }

代码示例来源：origin: com.dropbox.core/dropbox-core-sdk

  1. @Override
  2. public OutputStream getBody() {
  3.   // getBody() can be called multiple times to get access to the output stream. Don't
  4.   // error if this is the case.
  5.   if (body instanceof PipedRequestBody) {
  6.     return ((PipedRequestBody) body).getOutputStream();
  7.   } else {
  8.     PipedRequestBody pipedBody = new PipedRequestBody();
  9.     if (progressListener != null) {
  10.       pipedBody.setListener(progressListener);
  11.     }
  12.     setBody(pipedBody);
  13.     this.callback = new AsyncCallback();
  14.     this.call = client.newCall(request.build());
  15.     // enqueue the call (async call execution). This allows us to provide streaming uploads.
  16.     call.enqueue(callback);
  17.     return pipedBody.getOutputStream();
  18.   }
  19. }

代码示例来源：origin: cyforever123/ElectronicbrandProject

  1. /**
  2.  * 异步Get请求 具体实现（可取消）
  3.  *
  4.  * @param url             请求url
  5.  * @param activityName    请求activityName
  6.  * @param iTRequestResult 请求回调
  7.  * @param clazz           Class<T>
  8.  * @param params          请求参数
  9.  * @param <T>             泛型模板
  10.  */
  11. public <T> void requestAsyncGetEnqueueByTag(String url, String activityName, ITRequestResult<T> iTRequestResult, Class<T> clazz, Param... params) {
  12.   addRequestUrl(activityName, url);
  13.   String constructUrl = constructUrl(url, params);
  14.   Request request = new Request.Builder()
  15.       .get()
  16.       .url(constructUrl)
  17.       .tag(url)
  18.       .build();
  19.   mOkHttpClient.newCall(request).enqueue(new TRequestCallBack(iTRequestResult, clazz, activityName));
  20. }

代码示例来源：origin: cyforever123/ElectronicbrandProject

  1. /**
  2.  * 异步POST请求  具体实现
  3.  *
  4.  * @param url             请求url
  5.  * @param iTRequestResult 请求回调
  6.  * @param clazz           Class<T>
  7.  * @param params          请求参数
  8.  * @param <T>             泛型模板
  9.  */
  10. public <T> void requestAsyncPost(String url, ITRequestResult<T> iTRequestResult, Class<T> clazz, Param... params) {
  11.   FormEncodingBuilder builder = new FormEncodingBuilder();
  12.   for (Param param :
  13.       params) {
  14.     builder.add(param.key, param.value);
  15.   }
  16.   RequestBody body = builder.build();
  17.   Request request = new Request.Builder().post(body).url(url).build();
  18.   mOkHttpClient.newCall(request).enqueue(new TRequestCallBack(iTRequestResult, clazz));
  19. }

代码示例来源：origin: cyforever123/ElectronicbrandProject

  1. /**
  2.  * 异步POST请求  具体实现（可取消）
  3.  *
  4.  * @param url             请求url
  5.  * @param activityName    请求activityName
  6.  * @param iTRequestResult 请求回调
  7.  * @param clazz           Class<T>
  8.  * @param params          请求参数
  9.  * @param <T>             泛型模板
  10.  */
  11. public <T> void requestAsyncPostByTag(String url, String activityName, ITRequestResult<T> iTRequestResult, Class<T> clazz, Param... params) {
  12.   addRequestUrl(activityName, url);
  13.   FormEncodingBuilder builder = new FormEncodingBuilder();
  14.   for (Param param :
  15.       params) {
  16.     builder.add(param.key, param.value);
  17.   }
  18.   RequestBody body = builder.build();
  19.   Request request = new Request.Builder().post(body).url(url).tag(url).build();
  20.   mOkHttpClient.newCall(request).enqueue(new TRequestCallBack(iTRequestResult, clazz, activityName));
  21. }

内容来源于网络，如有侵权，请联系作者删除！

Call

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com