Lines Matching full:payload
40 return reinterpret_cast<const char*>(payload_.payload.data()); in Wait()
43 Function<void(const pw::rpc::Payload::Message&, Status)> UnaryOnCompleted() { in UnaryOnCompleted()
44 return [this](const pw::rpc::Payload::Message& data, Status) { in UnaryOnCompleted()
49 Function<void(const pw::rpc::Payload::Message&)> OnNext() { in OnNext()
50 return [this](const pw::rpc::Payload::Message& data) { CopyPayload(data); }; in OnNext()
54 void CopyPayload(const pw::rpc::Payload::Message& data) { in CopyPayload()
60 pw::rpc::Payload::Message payload_ = {};
64 pw::rpc::Payload::Message Payload(const char (&string)[kSize]) { in Payload() function
65 static_assert(kSize <= sizeof(pw::rpc::Payload::Message::payload)); in Payload()
66 pw::rpc::Payload::Message payload{}; in Payload() local
67 payload.payload.resize(kSize); in Payload()
68 std::memcpy(payload.payload.data(), string, kSize); in Payload()
69 return payload; in Payload()
83 kClient.UnaryEcho(Payload(value), receiver.UnaryOnCompleted()); in TEST()
89 pw::rpc::PwpbUnaryReceiver<pw::rpc::Payload::Message> call; in TEST()
96 call = kClient.UnaryEcho(Payload(value), receiver.UnaryOnCompleted()); in TEST()
104 kClient.UnaryEcho(Payload("O_o")); in TEST()
114 ASSERT_EQ(OkStatus(), call.Write(Payload("Yello"))); in TEST()
117 pw::rpc::PwpbClientReaderWriter<pw::rpc::Payload::Message, in TEST()
118 pw::rpc::Payload::Message> in TEST()
122 EXPECT_EQ(Status::FailedPrecondition(), call.Write(Payload("Dello"))); in TEST()
124 ASSERT_EQ(OkStatus(), new_call.Write(Payload("Dello"))); in TEST()
130 EXPECT_EQ(Status::FailedPrecondition(), new_call.Write(Payload("Dello"))); in TEST()
132 ASSERT_EQ(OkStatus(), call.Write(Payload("???"))); in TEST()
141 pw::rpc::PwpbClientReaderWriter<pw::rpc::Payload::Message, in TEST()
142 pw::rpc::Payload::Message> in TEST()
149 ASSERT_EQ(OkStatus(), call.Write(Payload("Yello"))); in TEST()
152 ASSERT_EQ(OkStatus(), call.Write(Payload("Dello"))); in TEST()
155 ASSERT_EQ(OkStatus(), call.Write(Payload("???"))); in TEST()