Searched refs:_conveyor (Results 1 – 2 of 2) sorted by relevance
374 self._conveyor = collections.defaultdict(408 if not self._conveyor:427 self._conveyor[i].put(_concat_arrays(431 result.append(self._conveyor[i].get(sync=self._sync_get))445 self._conveyor[key].put(_concat_arrays(449 result[key] = self._conveyor[key].get(sync=self._sync_get)
143 } _conveyor; typedef897 _conveyor conveyors[MAX_conveyors];