com.twitter.util.Future.respond()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(1.6k)|赞(0)|评价(0)|浏览(100)

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

Future.respond介绍

暂无

代码示例

代码示例来源:origin: pinterest/pinlater

@Override
 public Future<PinLaterDequeueResponse> apply(final Permit permit) {
  return futurePool.apply(new ExceptionalFunction0<PinLaterDequeueResponse>() {
   @Override
   public PinLaterDequeueResponse applyE() throws Throwable {
    return dequeueJobsImpl(source, request, numAutoRetries);
   }
  }).respond(new Function<Try<PinLaterDequeueResponse>, BoxedUnit>() {
   @Override
   public BoxedUnit apply(Try<PinLaterDequeueResponse> responseTry) {
    permit.release();
    return BoxedUnit.UNIT;
   }
  });
 }
});

代码示例来源:origin: pinterest/pinlater

queriesIssued.incrementAndGet();
permits.acquire();
iface.enqueueJobs(REQUEST_CONTEXT, request).respond(
  new Function<Try<PinLaterEnqueueResponse>, BoxedUnit>() {
   @Override

代码示例来源:origin: io.zipkin.finagle/zipkin-finagle

@Override public Void apply() {
  try {
   if (closeCalled) throw new IllegalStateException("closed");
   client.apply(makeRequest(spans)).respond(new AbstractFunction1<Try<Rep>, BoxedUnit>() {
    @Override public BoxedUnit apply(Try<Rep> result) {
     if (result.isReturn()) {
      callback.onComplete();
     } else {
      callback.onError(result.throwable());
     }
     return BoxedUnit.UNIT;
    }
   });
  } catch (Throwable e) {
   callback.onError(e);
   if (e instanceof Error) throw (Error) e;
  }
  return null;
 }
});

代码示例来源:origin: pinterest/pinlater

}).respond(new Function<Try<Void>, BoxedUnit>() {
@Override
public BoxedUnit apply(Try<Void> voidTry) {

相关文章