Searched refs:_streams (Results 1 – 7 of 7) sorted by relevance
77 while len(self._streams) > 0:78 self._streams[0].kill()79 self._streams.remove(self._streams[0])93 self._streams = []101 if not self._streams:103 elif len(self._streams) == self._MAX_STREAMS:114 self._streams.append(self._new_stream(stream_type))116 self._streams[0].kill()117 self._streams.remove(self._streams[0])
39 CObjectVector<CMyComPtr<IInStream> > _streams; member in NArchive::NSplit::CHandler62 case kpidNumVolumes: prop = (UInt32)_streams.Size(); break; in GetArchiveProperty()203 _streams.Add(stream); in Open2()206 const UInt64 numFiles = _streams.Size(); in Open2()236 _streams.Add(nextStream); in Open2()238 const UInt64 numFiles = _streams.Size(); in Open2()243 if (_streams.Size() == 1) in Open2()265 _streams.Clear(); in Close()272 *numItems = _streams.IsEmpty() ? 0 : 1; in GetNumberOfItems()318 FOR_VECTOR (i, _streams) in Extract()[all …]
180 self._streams = [189 self._streams[self._curr_stream].send_request()190 self._curr_stream = (self._curr_stream + 1) % len(self._streams)193 for stream in self._streams:197 for stream in self._streams:
291 self._streams = []307 self._streams.append(self.STREAM_MANAGER_CLASS(stream, level,332 for stream_manager in self._streams:344 for stream_manager in self._streams:360 for stream_manager in self._streams:366 for stream_manager in self._streams:463 for stream_handler in self._streams:
32 _streams = ('audio.mp3', 'audio.wav', 'audio.m4a') variable in audio_ActiveStreamStress78 if self._stream_index == len(self._streams):92 self._streams[self.get_stream_index()])))
139 self._streams = []146 self._streams.append(('cpu_uart_stream', 'cpu_uart.log'))149 self._streams.append(('ec_uart_stream', 'ec_uart.log'))160 for stream, logfile in self._streams:
74 .. _streams: