Home
last modified time | relevance | path

Searched refs:SendServerStream (Results 1 – 17 of 17) sorted by relevance

/external/pigweed/pw_transfer/
Dclient_test.cc110 context_.server().SendServerStream<Transfer::Read>( in TEST_F()
158 context_.server().SendServerStream<Transfer::Read>( in TEST_F()
167 context_.server().SendServerStream<Transfer::Read>( in TEST_F()
200 context_.server().SendServerStream<Transfer::Read>( in TEST_F()
220 context_.server().SendServerStream<Transfer::Read>( in TEST_F()
299 context_.server().SendServerStream<Transfer::Read>( in TEST_F()
315 context_.server().SendServerStream<Transfer::Read>( in TEST_F()
360 context_.server().SendServerStream<Transfer::Read>( in TEST_F()
371 context_.server().SendServerStream<Transfer::Read>( in TEST_F()
388 context_.server().SendServerStream<Transfer::Read>( in TEST_F()
[all …]
/external/pigweed/pw_rpc/nanopb/
Dclient_call_test.cc295 EXPECT_EQ(OkStatus(), context.SendServerStream(r1)); in TEST_F()
301 EXPECT_EQ(OkStatus(), context.SendServerStream(r2)); in TEST_F()
307 EXPECT_EQ(OkStatus(), context.SendServerStream(r3)); in TEST_F()
327 EXPECT_EQ(OkStatus(), context.SendServerStream(r1)); in TEST_F()
331 EXPECT_EQ(OkStatus(), context.SendServerStream(r2)); in TEST_F()
338 EXPECT_EQ(OkStatus(), context.SendServerStream(r3)); in TEST_F()
359 EXPECT_EQ(OkStatus(), context.SendServerStream(r1)); in TEST_F()
366 EXPECT_EQ(OkStatus(), context.SendServerStream(bad_payload)); in TEST_F()
Dcallback_test.cc84 context_.server().SendServerStream<TestService::TestBidirectionalStreamRpc>( in SendResponseAfterSemaphore()
253 context_.server().SendServerStream<TestService::TestBidirectionalStreamRpc>( in TEST_F()
Dcodegen_test.cc291 EXPECT_EQ(OkStatus(), context.SendServerStream(response)); in TEST()
377 EXPECT_EQ(OkStatus(), context.SendServerStream(response)); in TEST()
Dclient_reader_writer_test.cc390 ctx.server().SendServerStream<TestService::TestBidirectionalStreamRpc>( in TEST()
/external/pigweed/pw_rpc/pwpb/
Dclient_call_test.cc296 EXPECT_EQ(OkStatus(), context.SendServerStream(r1)); in TEST_F()
302 EXPECT_EQ(OkStatus(), context.SendServerStream(r2)); in TEST_F()
308 EXPECT_EQ(OkStatus(), context.SendServerStream(r3)); in TEST_F()
328 EXPECT_EQ(OkStatus(), context.SendServerStream(r1)); in TEST_F()
332 EXPECT_EQ(OkStatus(), context.SendServerStream(r2)); in TEST_F()
339 EXPECT_EQ(OkStatus(), context.SendServerStream(r3)); in TEST_F()
360 EXPECT_EQ(OkStatus(), context.SendServerStream(r1)); in TEST_F()
367 EXPECT_EQ(OkStatus(), context.SendServerStream(bad_payload)); in TEST_F()
Dcodegen_test.cc346 EXPECT_EQ(OkStatus(), context.SendServerStream(response)); in TEST()
433 EXPECT_EQ(OkStatus(), context.SendServerStream(response)); in TEST()
Dclient_reader_writer_test.cc387 ctx.server().SendServerStream<TestService::TestBidirectionalStreamRpc>( in TEST()
/external/pigweed/pw_rpc/pwpb/public/pw_rpc/pwpb/
Dclient_testing.h60 void SendServerStream(const Response<kMethod>& payload) const { in SendServerStream() function
62 FakeServer::SendServerStream<kMethod>( in SendServerStream()
/external/pigweed/pw_rpc/nanopb/public/pw_rpc/nanopb/
Dclient_testing.h64 void SendServerStream(const Response<kMethod>& payload,
67 FakeServer::SendServerStream<kMethod>(
Dserver_reader_writer.h84 Status SendServerStream(const void* payload) PW_LOCKS_EXCLUDED(rpc_lock()) { in SendServerStream() function
195 return internal::NanopbServerCall::SendServerStream(&response); in Write()
336 return internal::NanopbServerCall::SendServerStream(&response); in Write()
/external/pigweed/pw_rpc/
Dcallback_test.cc80 context_.server().SendServerStream<TestService::TestBidirectionalStreamRpc>( in SendResponseAfterSemaphore()
241 context_.server().SendServerStream<TestService::TestBidirectionalStreamRpc>( in TEST_F()
/external/pigweed/pw_rpc/raw/
Dcodegen_test.cc486 .SendServerStream<test::pw_rpc::raw::TestService::TestServerStreamRpc>( in TEST_F()
493 .SendServerStream<test::pw_rpc::raw::TestService::TestServerStreamRpc>( in TEST_F()
623 .SendServerStream< in TEST_F()
Dclient_test.cc144 context.server().SendServerStream<BidirectionalStreamMethod>( in TEST()
186 context.server().SendServerStream<BidirectionalStreamMethod>({}); in TEST()
Dclient_reader_writer_test.cc608 ctx.server().SendServerStream<TestService::TestBidirectionalStreamRpc>( in TEST()
611 ctx.server().SendServerStream<TestService::TestBidirectionalStreamRpc>( in TEST()
/external/pigweed/pw_rpc/raw/public/pw_rpc/raw/
Dclient_testing.h70 void SendServerStream(ConstByteSpan payload,
/external/pigweed/pw_rpc/public/pw_rpc/internal/
Dtest_utils.h158 Status SendServerStream(span<const std::byte> payload) { in SendServerStream() function