本文整理了Java中com.twitter.util.Future.respond()
方法的一些代码示例,展示了Future.respond()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Future.respond()
方法的具体详情如下:
包路径:com.twitter.util.Future
类名称: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) {
内容来源于网络,如有侵权,请联系作者删除!