Deque

ABC Pipeline with Deque

---

source

PipelineDQ

Pipeline with Deque for double-ended processing unit in dataflow

---

source

PipelineDQ.get_data

 PipelineDQ.get_data ()

*Get data from the pipeline

return: data: data from the pipeline*

---

source

PipelineDQ.put_data

 PipelineDQ.put_data (value:~T)

*Put data into the pipeline

arg:

value: data to be put into the pipeline

return:

None*

---

source

PipelineDQ.clear

 PipelineDQ.clear ()

*clear the pipeline (Deque)

collection.deque has a clear method. Just call it.*