retrofit2.Call.clone()方法的使用及代码示例

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

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

Call.clone介绍

[英]Create a new, identical call to this one which can be enqueued or executed even if this call has already been.
[中]创建一个与此调用相同的新调用，该调用可以排队或执行，即使此调用已经完成。

代码示例

代码示例来源：origin: resilience4j/resilience4j

  1. @Override
  2. public Call<T> clone() {
  3.   return call.clone();
  4. }

代码示例来源：origin: square/retrofit

  1. @Override public MyCall<T> clone() {
  2.   return new MyCallAdapter<>(call.clone(), callbackExecutor);
  3.  }
  4. }

代码示例来源：origin: square/retrofit

  1. @SuppressWarnings("CloneDoesntCallSuperClone") // Performing deep clone.
  2. @Override public Call<T> clone() {
  3.  return new ExecutorCallbackCall<>(callbackExecutor, delegate.clone());
  4. }

代码示例来源：origin: square/retrofit

  1. @SuppressWarnings("CloneDoesntCallSuperClone") // We are a final type & this saves clearing state.
  2. @Override public Call<T> clone() {
  3.  return new BehaviorCall<>(behavior, backgroundExecutor, delegate.clone());
  4. }

代码示例来源：origin: square/retrofit

  1. @Override protected void subscribeActual(Observer<? super Response<T>> observer) {
  2.  // Since Call is a one-shot type, clone it for each new observer.
  3.  Call<T> call = originalCall.clone();
  4.  CallCallback<T> callback = new CallCallback<>(call, observer);
  5.  observer.onSubscribe(callback);
  6.  if (!callback.isDisposed()) {
  7.   call.enqueue(callback);
  8.  }
  9. }

代码示例来源：origin: com.squareup.retrofit2/retrofit

  1. @SuppressWarnings("CloneDoesntCallSuperClone") // Performing deep clone.
  2. @Override public Call<T> clone() {
  3.  return new ExecutorCallbackCall<>(callbackExecutor, delegate.clone());
  4. }

代码示例来源：origin: square/retrofit

  1. @Override public void call(Subscriber<? super Response<T>> subscriber) {
  2.   // Since Call is a one-shot type, clone it for each new subscriber.
  3.   Call<T> call = originalCall.clone();
  4.   final CallArbiter<T> arbiter = new CallArbiter<>(call, subscriber);
  5.   subscriber.add(arbiter);
  6.   subscriber.setProducer(arbiter);
  8.   call.enqueue(new Callback<T>() {
  9.    @Override public void onResponse(Call<T> call, Response<T> response) {
  10.     arbiter.emitResponse(response);
  11.    }
  13.    @Override public void onFailure(Call<T> call, Throwable t) {
  14.     Exceptions.throwIfFatal(t);
  15.     arbiter.emitError(t);
  16.    }
  17.   });
  18.  }
  19. }

代码示例来源：origin: square/retrofit

  1. @Override public void call(Subscriber<? super Response<T>> subscriber) {
  2.   // Since Call is a one-shot type, clone it for each new subscriber.
  3.   Call<T> call = originalCall.clone();
  4.   CallArbiter<T> arbiter = new CallArbiter<>(call, subscriber);
  5.   subscriber.add(arbiter);
  6.   subscriber.setProducer(arbiter);
  8.   Response<T> response;
  9.   try {
  10.    response = call.execute();
  11.   } catch (Throwable t) {
  12.    Exceptions.throwIfFatal(t);
  13.    arbiter.emitError(t);
  14.    return;
  15.   }
  16.   arbiter.emitResponse(response);
  17.  }
  18. }

代码示例来源：origin: resilience4j/resilience4j

  1. @Test
  2. public void passThroughCallsToDecoratedObject() throws IOException {
  3.   final Call<String> call = mock(StringCall.class);
  4.   final Call<String> decorated = new DecoratedCall<>(call);
  5.   decorated.cancel();
  6.   Mockito.verify(call).cancel();
  7.   decorated.enqueue(null);
  8.   Mockito.verify(call).enqueue(any());
  9.   decorated.isExecuted();
  10.   Mockito.verify(call).isExecuted();
  11.   decorated.isCanceled();
  12.   Mockito.verify(call).isCanceled();
  13.   decorated.clone();
  14.   Mockito.verify(call).clone();
  15.   decorated.request();
  16.   Mockito.verify(call).request();
  17.   decorated.execute();
  18.   Mockito.verify(call).execute();
  19. }

代码示例来源：origin: square/retrofit

  1. @Override protected void subscribeActual(Observer<? super Response<T>> observer) {
  2.  Call<T> call = originalCall.clone();
  3.  CallDisposable disposable = new CallDisposable(call);
  4.  observer.onSubscribe(disposable);

代码示例来源：origin: mapbox/mapbox-java

  1. /**
  2.  * Wrapper method for Retrofit's {@link Call#clone()} call, useful for getting call information.
  3.  *
  4.  * @return cloned call
  5.  * @since 3.5.0
  6.  */
  7. public Call<List<FeatureCollection>> cloneBatchCall() {
  8.  return getBatchCall().clone();
  9. }

代码示例来源：origin: gradle.plugin.de.qaware.cloud.deployer/deployer

  1. /**
  2.  * Retries a call after a waiting period.
  3.  *
  4.  * @return The response of the call.
  5.  */
  6. private Response<ResponseBody> retryCall(Call<ResponseBody> call) throws IOException, InterruptedException {
  7.   Thread.sleep(SERVER_ERROR_WAITING_TIME * 1000);
  8.   return call.clone().execute();
  9. }

代码示例来源：origin: mapbox/mapbox-java

  1. /**
  2.  * Wrapper method for Retrofits {@link Call#clone()} call, useful for getting call information.
  3.  *
  4.  * @return cloned call
  5.  * @since 1.0.0
  6.  */
  7. public Call<List<GeocodingResponse>> cloneBatchCall() {
  8.  return getBatchCall().clone();
  9. }

代码示例来源：origin: mapbox/mapbox-java

  1. /**
  2.  * Wrapper method for Retrofit's {@link Call#clone()} call, useful for getting call information.
  3.  *
  4.  * @return cloned call
  5.  * @since 3.5.0
  6.  */
  7. public Call<List<FeatureCollection>> cloneBatchCall() {
  8.  return getBatchCall().clone();
  9. }

代码示例来源：origin: mapbox/mapbox-java

  1. /**
  2.  * Wrapper method for Retrofits {@link Call#clone()} call, useful for getting call information.
  3.  *
  4.  * @return cloned call
  5.  * @since 3.0.0
  6.  */
  7. public Call<T> cloneCall() {
  8.  return getCall().clone();
  9. }

代码示例来源：origin: com.mapbox.mapboxsdk/mapbox-sdk-services

  1. /**
  2.  * Wrapper method for Retrofits {@link Call#clone()} call, useful for getting call information.
  3.  *
  4.  * @return cloned call
  5.  * @since 1.0.0
  6.  */
  7. public Call<List<GeocodingResponse>> cloneBatchCall() {
  8.  return getBatchCall().clone();
  9. }

代码示例来源：origin: VictorAlbertos/Mockery

  1. @Override public Object adaptResponse(Object response, Metadata<Retrofit> metadata) {
  2.  checkReturnMethodTypeIsCall(metadata);
  3.  Call call = (Call) response;
  4.  try {
  5.   Response payload = call.clone().execute();
  6.   Object body = payload.body();
  7.   return body;
  8.  } catch (IOException e) {
  9.   throw new RuntimeException(e);
  10.  }
  11. }

代码示例来源：origin: JakeWharton/retrofit2-reactor-adapter

  1. @Override public void accept(FluxSink<Response<T>> sink) {
  2.  // Since Call is a one-shot type, clone it for each new subscriber.
  3.  Call<T> call = originalCall.clone();
  4.  DisposableCallback<T> callback = new DisposableCallback<>(call, sink);
  5.  sink.onDispose(callback);
  6.  call.enqueue(callback);
  7. }

代码示例来源：origin: iagocanalejas/retrocache

  1. @Override
  2. public Cached<T> clone() {
  3.   return new CachedCall<>(mExecutor, mCall.clone(), responseType(),
  4.       mAnnotations, mRetrofit, mCachingSystem);
  5. }

代码示例来源：origin: lizubing1992/Smartcacheforretrofit2

  1. @Override
  2. public SmartCall<T> clone() {
  3.   return new SmartCallImpl<>(callbackExecutor, baseCall.clone(), responseType(),
  4.       annotations, retrofit, cachingSystem);
  5. }

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

Call

相关文章

    查看更多

    热门标签

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

    最新文章

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