Searched refs:receiver_stream (Results 1 – 2 of 2) sorted by relevance
82 auto* receiver_stream = stream_it_pair.second->second; in RunTasks() local89 receiver_stream->delegate()->OnReceived( in RunTasks()90 receiver_stream, reinterpret_cast<const char*>(written_data.data()), in RunTasks()94 written_data = receiver_stream->TakeWrittenData(); in RunTasks()95 OSP_DCHECK(receiver_stream->TakeReceivedData().empty()); in RunTasks()106 receiver_stream->CloseReadEnd(); in RunTasks()108 if (receiver_stream->write_end_closed()) { in RunTasks()113 receiver_stream->both_ends_closed()) { in RunTasks()115 receiver_stream->delegate()->OnClose(receiver_stream->id()); in RunTasks()118 receiver_stream->delegate()->OnReceived(receiver_stream, nullptr, 0); in RunTasks()
145 std::unique_ptr<ProtocolConnection> receiver_stream; in TEST_F() local156 [&receiver_stream](std::unique_ptr<ProtocolConnection>& connection) { in TEST_F()157 receiver_stream = std::move(connection); in TEST_F()162 ASSERT_TRUE(receiver_stream); in TEST_F()166 uint64_t controller_endpoint_id = receiver_stream->endpoint_id(); in TEST_F()171 std::move(receiver_stream)); in TEST_F()