本文整理了Java中io.vertx.core.Future.completer()
方法的一些代码示例,展示了Future.completer()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Future.completer()
方法的具体详情如下:
包路径:io.vertx.core.Future
类名称:Future
方法名:completer
暂无
代码示例来源:origin: vert-x3/vertx-examples
/**
* <pre>
* One empty request followed by one empty response.
* </pre>
*/
public void emptyCall(io.vertx.example.grpc.EmptyProtos.Empty request,
io.vertx.core.Future<io.vertx.example.grpc.EmptyProtos.Empty> response) {
asyncUnimplementedUnaryCall(getEmptyCallMethod(), EmptyPingPongServiceGrpc.toObserver(response.completer()));
}
代码示例来源:origin: vert-x3/vertx-examples
/**
* <pre>
* A simple RPC.
* Obtains the feature at a given position.
* A feature with an empty name is returned if there's no feature at the given
* position.
* </pre>
*/
public void getFeature(io.grpc.examples.routeguide.Point request,
io.vertx.core.Future<io.grpc.examples.routeguide.Feature> response) {
asyncUnimplementedUnaryCall(getGetFeatureMethod(), RouteGuideGrpc.toObserver(response.completer()));
}
代码示例来源:origin: vert-x3/vertx-examples
/**
* <pre>
* One request followed by one response.
* </pre>
*/
public void unaryCall(io.vertx.example.grpc.Messages.SimpleRequest request,
io.vertx.core.Future<io.vertx.example.grpc.Messages.SimpleResponse> response) {
asyncUnimplementedUnaryCall(getUnaryCallMethod(), PingPongServiceGrpc.toObserver(response.completer()));
}
代码示例来源:origin: vert-x3/vertx-examples
/**
* <pre>
* Sends a greeting
* </pre>
*/
public void sayHello(io.grpc.examples.helloworld.HelloRequest request,
io.vertx.core.Future<io.grpc.examples.helloworld.HelloReply> response) {
asyncUnimplementedUnaryCall(getSayHelloMethod(), GreeterGrpc.toObserver(response.completer()));
}
代码示例来源:origin: vert-x3/vertx-examples
/**
* <pre>
* A client-to-server streaming RPC.
* Accepts a stream of Points on a route being traversed, returning a
* RouteSummary when traversal is completed.
* </pre>
*/
public void recordRoute(io.vertx.grpc.GrpcReadStream<io.grpc.examples.routeguide.Point> request,
io.vertx.core.Future<io.grpc.examples.routeguide.RouteSummary> response) {
request.setReadObserver(asyncUnimplementedStreamingCall(getRecordRouteMethod(), RouteGuideGrpc.toObserver(response.completer())));
}
代码示例来源:origin: vert-x3/vertx-examples
@Override
public void start(Future<Void> future) {
startTransactionService();
startHttpServer().setHandler(future.completer());
}
代码示例来源:origin: vert-x3/vertx-examples
/**
* <pre>
* A sequence of requests followed by one response (streamed upload).
* The server returns the aggregated size of client payload as the result.
* </pre>
*/
public void streamingInputCall(io.vertx.grpc.GrpcReadStream<io.vertx.example.grpc.Messages.StreamingInputCallRequest> request,
io.vertx.core.Future<io.vertx.example.grpc.Messages.StreamingInputCallResponse> response) {
request.setReadObserver(asyncUnimplementedStreamingCall(getStreamingInputCallMethod(), ProducerServiceGrpc.toObserver(response.completer())));
}
代码示例来源:origin: eclipse-vertx/vert.x
@Override
public void start() throws Exception {
JsonObject config = config();
id = config.getInteger("id");
numAddresses = config.getInteger("addressesCount");
List<Future> registrationFutures = new ArrayList<>(numAddresses);
for (int i = 0; i < numAddresses; i++) {
Future<Void> registrationFuture = Future.future();
registrationFutures.add(registrationFuture);
vertx.eventBus().consumer(createAddress(id, i), msg -> msg.reply("pong")).completionHandler(registrationFuture.completer());
}
Future<Void> registrationFuture = Future.future();
registrationFutures.add(registrationFuture);
vertx.eventBus().consumer("ping", this::ping).completionHandler(registrationFuture.completer());
CompositeFuture.all(registrationFutures).setHandler(ar -> {
if (ar.succeeded()) {
vertx.eventBus().send("control", "start");
}
});
}
代码示例来源:origin: strimzi/strimzi-kafka-operator
@Override
public void handle(Future<Void> fut) {
TopicOperator.this.reconcileOnTopicChange(topicName, null, fut.completer());
}
};
代码示例来源:origin: io.vertx/vertx-core
@Override
public void start() throws Exception {
JsonObject config = config();
id = config.getInteger("id");
numAddresses = config.getInteger("addressesCount");
List<Future> registrationFutures = new ArrayList<>(numAddresses);
for (int i = 0; i < numAddresses; i++) {
Future<Void> registrationFuture = Future.future();
registrationFutures.add(registrationFuture);
vertx.eventBus().consumer(createAddress(id, i), msg -> msg.reply("pong")).completionHandler(registrationFuture.completer());
}
Future<Void> registrationFuture = Future.future();
registrationFutures.add(registrationFuture);
vertx.eventBus().consumer("ping", this::ping).completionHandler(registrationFuture.completer());
CompositeFuture.all(registrationFutures).setHandler(ar -> {
if (ar.succeeded()) {
vertx.eventBus().send("control", "start");
}
});
}
代码示例来源:origin: strimzi/strimzi-kafka-operator
@Override
public void handle(Future<Void> fut) {
kafka.topicMetadata(topicName, metadataResult -> {
if (metadataResult.succeeded()) {
Topic topic = TopicSerialization.fromTopicMetadata(metadataResult.result());
TopicOperator.this.reconcileOnTopicChange(topicName, topic, fut.completer());
} else {
fut.fail(metadataResult.cause());
}
});
}
};
代码示例来源:origin: sczyh30/vertx-blueprint-microservice
protected Future<SQLConnection> getConnection() {
Future<SQLConnection> future = Future.future();
client.getConnection(future.completer());
return future;
}
代码示例来源:origin: sczyh30/vertx-blueprint-microservice
/**
* Get all REST endpoints from the service discovery infrastructure.
*
* @return async result
*/
private Future<List<Record>> getAllEndpoints() {
Future<List<Record>> future = Future.future();
discovery.getRecords(record -> record.getType().equals(HttpEndpoint.TYPE),
future.completer());
return future;
}
代码示例来源:origin: sczyh30/vertx-blueprint-microservice
@Override
public Future<Integer> decrease(String productId, int decrease) {
Future<Long> future = Future.future();
client.decrby(PREFIX + productId, decrease, future.completer());
return future.map(Long::intValue);
}
代码示例来源:origin: sczyh30/vertx-blueprint-microservice
private Future<Void> deployRestService(ProductService service) {
Future<String> future = Future.future();
vertx.deployVerticle(new RestProductAPIVerticle(service),
new DeploymentOptions().setConfig(config()),
future.completer());
return future.map(r -> null);
}
代码示例来源:origin: sczyh30/vertx-blueprint-microservice
private Future<Void> prepareDispatcher() {
Future<String> future = Future.future();
vertx.deployVerticle(new RawOrderDispatcher(orderService),
new DeploymentOptions().setConfig(config()),
future.completer());
return future.map(r -> null);
}
代码示例来源:origin: sczyh30/vertx-blueprint-microservice
private Future<Void> deployRestVerticle() {
Future<String> future = Future.future();
vertx.deployVerticle(new RestShoppingAPIVerticle(shoppingCartService, checkoutService),
new DeploymentOptions().setConfig(config()),
future.completer());
return future.map(r -> null);
}
代码示例来源:origin: sczyh30/vertx-blueprint-microservice
private Future<Void> initProductDatabase(ProductService service) {
Future<Void> initFuture = Future.future();
service.initializePersistence(initFuture.completer());
return initFuture.map(v -> {
ExampleHelper.initData(vertx, config());
return null;
});
}
代码示例来源:origin: sczyh30/vertx-blueprint-microservice
@Override
public void start(Future<Void> future) throws Exception {
super.start();
// create the service instance
accountService = new JdbcAccountServiceImpl(vertx, config());
// register the service proxy on event bus
ProxyHelper.registerService(AccountService.class, vertx, accountService, SERVICE_ADDRESS);
// publish the service and REST endpoint in the discovery infrastructure
publishEventBusService(SERVICE_NAME, SERVICE_ADDRESS, AccountService.class)
.compose(servicePublished -> deployRestVerticle())
.setHandler(future.completer());
}
代码示例来源:origin: sczyh30/vertx-blueprint-microservice
@Override
public void start(Future<Void> future) throws Exception {
super.start();
this.orderService = new OrderServiceImpl(vertx, config());
ProxyHelper.registerService(OrderService.class, vertx, orderService, SERVICE_ADDRESS);
initOrderDatabase()
.compose(databaseOkay -> publishEventBusService(SERVICE_NAME, SERVICE_ADDRESS, OrderService.class))
.compose(servicePublished -> prepareDispatcher())
.compose(dispatcherPrepared -> deployRestVerticle())
.setHandler(future.completer());
}
内容来源于网络,如有侵权,请联系作者删除!