Queue

ABC Pipeline with Queue

---

source

Pipeline

 Pipeline (maxsize=0)

Pipeline class from Queue for single-ended unit in dataflow

---

source

Pipeline.get_data

 Pipeline.get_data ()

*Get data from the pipeline

return: data: data from the pipeline*

---

source

Pipeline.put_data

 Pipeline.put_data (value:~T)

*Put data into the pipeline

arg:

value: data to be put into the pipeline

return:

None*

---

source

Pipeline.clear

 Pipeline.clear ()

*clear the pipeline (Queue) as the standard Queue

since python queue.Queue does not have clear() method*