Searched refs:controller_stream (Results 1 – 2 of 2) sorted by relevance
81 auto* controller_stream = stream_it_pair.first->second; in RunTasks() local84 std::vector<uint8_t> written_data = controller_stream->TakeWrittenData(); in RunTasks()85 OSP_DCHECK(controller_stream->TakeReceivedData().empty()); in RunTasks()99 controller_stream->delegate()->OnReceived( in RunTasks()100 controller_stream, reinterpret_cast<const char*>(written_data.data()), in RunTasks()105 if (controller_stream->write_end_closed()) { in RunTasks()109 controller_stream->CloseReadEnd(); in RunTasks()112 if (controller_stream->both_ends_closed() && in RunTasks()114 controller_stream->delegate()->OnClose(controller_stream->id()); in RunTasks()117 controller_stream->delegate()->OnReceived(controller_stream, nullptr, 0); in RunTasks()
144 std::unique_ptr<ProtocolConnection> controller_stream; in TEST_F() local149 .WillOnce(Invoke([&controller_stream](uint64_t request_id, in TEST_F()151 controller_stream.reset(stream); in TEST_F()161 ASSERT_TRUE(controller_stream); in TEST_F()167 uint64_t receiver_endpoint_id = controller_stream->endpoint_id(); in TEST_F()169 std::move(controller_stream)); in TEST_F()