Package com.googlecode.protobuf.socketrpc.TestProtos.TestService

Examples of com.googlecode.protobuf.socketrpc.TestProtos.TestService.BlockingInterface.testMethod()

331
332
333
334
335
336
337
338
339
340
341
  private Response callBlockingRpc(Request request, ErrorReason reason) {
    SocketRpcController controller = new SocketRpcController();
    BlockingInterface service = TestService.newBlockingStub(rpcChannel);
    try {
      Response response = service.testMethod(controller, request);
      assertNull(reason);
      return response;
    } catch (ServiceException e) {
      assertEquals(reason, controller.errorReason());
      return null;
View Full Code Here
312
313
314
315
316
317
318
319
320
321
322
  private Response callSync(SocketRpcChannel rpcChannel,
      Request request, ErrorReason reason) {
    SocketRpcController controller = rpcChannel.newRpcController();
    BlockingInterface service = TestService.newBlockingStub(rpcChannel);
    try {
      Response response = service.testMethod(controller, request);
      assertNull(reason);
      return response;
    } catch (ServiceException e) {
      assertEquals(reason, controller.errorReason());
      return null;
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.