Searched refs:source_streams_ (Results 1 – 2 of 2) sorted by relevance
18 : source_streams_{std::move(source_streams)}, in InputStreamSet()78 for (const Stream* stream : source_streams_) { in CanGetSize()97 for (const Stream* stream : source_streams_) in GetRemainingSize()117 while (!source_streams_.empty()) { in ReadNonBlocking()118 Stream* stream = source_streams_.front(); in ReadNonBlocking()129 source_streams_.erase(source_streams_.begin()); in ReadNonBlocking()152 source_streams_.clear(); in CloseBlocking()168 if (!source_streams_.empty()) { in WaitForData()169 Stream* stream = source_streams_.front(); in WaitForData()187 if (!source_streams_.empty()) { in WaitForDataBlocking()[all …]
117 std::vector<Stream*> source_streams_; variable