Package com.googlecode.protobuf.socketrpc.TestProtos

Examples of com.googlecode.protobuf.socketrpc.TestProtos.Response.toByteString()

69
70
71
72
73
74
75
76
77
78
79
    // Test doBlockingRpc
    SocketRpcProtos.Response rpcResponse =
        rpcForwarder.doBlockingRpc(RPC_REQUEST);
    assertTrue(rpcResponse.getCallback());
    assertEquals(response.toByteString(), rpcResponse.getResponseProto());

    // Test doRpc
    Callback<SocketRpcProtos.Response> rpcCallback =
        new Callback<SocketRpcProtos.Response>();
    rpcForwarder.doRpc(RPC_REQUEST, rpcCallback);
View Full Code Here
78
79
80
81
82
83
84
85
86
87
88
        new Callback<SocketRpcProtos.Response>();
    rpcForwarder.doRpc(RPC_REQUEST, rpcCallback);
    assertTrue(rpcCallback.isInvoked());
    rpcResponse = rpcCallback.getResponse();
    assertTrue(rpcResponse.getCallback());
    assertEquals(response.toByteString(), rpcResponse.getResponseProto());

    // Register BlockingService
    response = Response.newBuilder().setStrData("New Data").build();
    rpcForwarder.registerBlockingService(new FakeServiceImpl(REQUEST)
        .withResponse(response).toBlockingService());
View Full Code Here
88
89
90
91
92
93
94
95
96
97
98
        .withResponse(response).toBlockingService());

    // Test doBlockingRpc
    rpcResponse = rpcForwarder.doBlockingRpc(RPC_REQUEST);
    assertTrue(rpcResponse.getCallback());
    assertEquals(response.toByteString(), rpcResponse.getResponseProto());

    // Test doRpc
    rpcCallback = new Callback<SocketRpcProtos.Response>();
    rpcForwarder.doRpc(RPC_REQUEST, rpcCallback);
    assertTrue(rpcCallback.isInvoked());
View Full Code Here
96
97
98
99
100
101
102
103
104
105
106
    rpcCallback = new Callback<SocketRpcProtos.Response>();
    rpcForwarder.doRpc(RPC_REQUEST, rpcCallback);
    assertTrue(rpcCallback.isInvoked());
    rpcResponse = rpcCallback.getResponse();
    assertTrue(rpcResponse.getCallback());
    assertEquals(response.toByteString(), rpcResponse.getResponseProto());
  }

  /**
   * Successful RPC but callback is not called.
   */
 
View Full Code Here
139
140
141
142
143
144
145
146
147
148
149
    // Do delayed callback
    fakeServiceImpl.callback.run(response);

    // Verify result
    assertTrue(fakeConnection.response.getCallback());
    assertEquals(response.toByteString(),
        fakeConnection.response.getResponseProto());
  }

  /**
   * Test async request with null response.
View Full Code Here
83
84
85
86
87
88
89
90
91
92
93
    socketRpcLocalServer.new ConnectionHandler(
        new SocketConnection(socket, false)).run();

    // Verify result
    assertTrue(socket.getResponse().getCallback());
    assertEquals(response.toByteString(),
        socket.getResponse().getResponseProto());
  }

  /**
   * Test good request/response
View Full Code Here
103
104
105
106
107
108
109
110
111
112
113
    FakeSocket socket = new FakeSocket(false).withRequest(RPC_REQUEST);
    runHandler(socket);

    // Verify result
    assertTrue(socket.getResponse().getCallback());
    assertEquals(response.toByteString(),
        socket.getResponse().getResponseProto());
  }

  /**
   * Successful RPC but callback is not called.
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.