Lines Matching refs:RpcPacket

21 from pw_rpc.internal.packet_pb2 import PacketType, RpcPacket
24 _TEST_REQUEST = RpcPacket(type=PacketType.REQUEST,
28                           payload=RpcPacket(status=321).SerializeToString())
34         data = packets.encode_request((1, 2, 3), RpcPacket(status=321))
35         packet = RpcPacket()
41         response = RpcPacket(type=PacketType.RESPONSE,
45                              payload=RpcPacket(status=321).SerializeToString())
47         data = packets.encode_response((1, 2, 3), RpcPacket(status=321))
48         packet = RpcPacket()
56         packet = RpcPacket()
61             RpcPacket(type=PacketType.CANCEL_SERVER_STREAM,
69         packet = RpcPacket()
74             RpcPacket(type=PacketType.CLIENT_ERROR,
89                 RpcPacket(type=PacketType.RESPONSE,
93                           payload=RpcPacket(status=321).SerializeToString())))