La documentación de gRPC nos muestra dos formas de realizar la comunicación con el servidor:
- blocking/synchronous
- non-blocking/asynchronous
Y el código (Java) generado para el cliente, se indican estos dos ejemplos de Stub.
blockingStub = RouteGuideGrpc.newBlockingStub(channel);
asyncStub = RouteGuideGrpc.newStub(channel);
Con asyncStub debemos usar StreamObserver para consumir la respuesta.
Sin embargo, dentro de las clases del tipo asíncrono tendremos la opción de usar el método newFutureSutb. Con él, adicionamos el control mediante callbacks.
El siguiente ejemplo, nos muestra este uso.
Top comments (0)