Lines Matching full:payload
39 return reinterpret_cast<const char*>(payload_.payload.data()); in Wait()
42 Function<void(const pw::rpc::Payload::Message&, Status)> UnaryOnCompleted() { in UnaryOnCompleted()
43 return [this](const pw::rpc::Payload::Message& data, Status) { in UnaryOnCompleted()
48 Function<void(const pw::rpc::Payload::Message&)> OnNext() { in OnNext()
49 return [this](const pw::rpc::Payload::Message& data) { CopyPayload(data); }; in OnNext()
53 void CopyPayload(const pw::rpc::Payload::Message& data) { in CopyPayload()
59 pw::rpc::Payload::Message payload_ = {};
63 pw::rpc::Payload::Message Payload(const char (&string)[kSize]) { in Payload() function
64 static_assert(kSize <= sizeof(pw::rpc::Payload::Message::payload)); in Payload()
65 pw::rpc::Payload::Message payload{}; in Payload() local
66 payload.payload.resize(kSize); in Payload()
67 std::memcpy(payload.payload.data(), string, kSize); in Payload()
68 return payload; in Payload()
82 kClient.UnaryEcho(Payload(value), receiver.UnaryOnCompleted()); in TEST()
88 pw::rpc::PwpbUnaryReceiver<pw::rpc::Payload::Message> call; in TEST()
95 call = kClient.UnaryEcho(Payload(value), receiver.UnaryOnCompleted()); in TEST()
103 kClient.UnaryEcho(Payload("O_o")); in TEST()
113 ASSERT_EQ(OkStatus(), call.Write(Payload("Yello"))); in TEST()
116 pw::rpc::PwpbClientReaderWriter<pw::rpc::Payload::Message, in TEST()
117 pw::rpc::Payload::Message> in TEST()
121 EXPECT_EQ(Status::FailedPrecondition(), call.Write(Payload("Dello"))); in TEST()
123 ASSERT_EQ(OkStatus(), new_call.Write(Payload("Dello"))); in TEST()
129 EXPECT_EQ(Status::FailedPrecondition(), new_call.Write(Payload("Dello"))); in TEST()
131 ASSERT_EQ(OkStatus(), call.Write(Payload("???"))); in TEST()
140 pw::rpc::PwpbClientReaderWriter<pw::rpc::Payload::Message, in TEST()
141 pw::rpc::Payload::Message> in TEST()
148 ASSERT_EQ(OkStatus(), call.Write(Payload("Yello"))); in TEST()
151 ASSERT_EQ(OkStatus(), call.Write(Payload("Dello"))); in TEST()
154 ASSERT_EQ(OkStatus(), call.Write(Payload("???"))); in TEST()