本文整理了Java中io.trane.future.Future.onSuccess()
方法的一些代码示例,展示了Future.onSuccess()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Future.onSuccess()
方法的具体详情如下:
包路径:io.trane.future.Future
类名称:Future
方法名:onSuccess
[英]Executes the Consumer if this future completes successfully.
[中]如果此future成功完成,则执行使用者。
代码示例来源:origin: traneio/future
@Override
final Future<T> apply(final Future<T> result) {
return result.onSuccess(c);
}
}
代码示例来源:origin: traneio/ndbc
protected final <T> CompletionStage<T> conv(final Future<T> fut) {
final CompletableFuture<T> cf = new CompletableFuture<>();
fut.onSuccess(cf::complete).onFailure(cf::completeExceptionally);
return cf;
}
代码示例来源:origin: traneio/ndbc
protected final <T> Future<T> convert(final io.trane.future.Future<T> future) {
final Promise<T> promise = Promise$.MODULE$.apply();
future.onSuccess(promise::success).onFailure(promise::failure);
return promise.future();
}
代码示例来源:origin: traneio/ndbc
protected final <T> Future<T> convert(final io.trane.future.Future<T> future) {
final Promise<T> promise = Promise$.MODULE$.apply();
future.onSuccess(promise::success).onFailure(promise::failure);
return promise.future();
}
代码示例来源:origin: traneio/ndbc
protected final <T> Future<T> convert(final io.trane.future.Future<T> future) {
final Promise<T> promise = Promise.apply();
promise.setInterruptHandler(new PartialFunction<Throwable, BoxedUnit>() {
@Override
public BoxedUnit apply(final Throwable v1) {
future.raise(v1);
return BoxedUnit.UNIT;
}
@Override
public boolean isDefinedAt(final Throwable x) {
return true;
}
});
future.onSuccess(promise::setValue).onFailure(promise::setException);
return promise;
}
代码示例来源:origin: traneio/ndbc
return channel.ctx().onSuccess(ctx -> {
final SSLEngine sslEngine = sslContext.newEngine(ctx.alloc(), host, port);
if (cfg.mode() == Mode.VERIFY_FULL) {
内容来源于网络,如有侵权,请联系作者删除!