Producer

ABC Producer

---

source

Producer

 Producer ()

Producer produce data into the pipeline. It provides the unified interface for data capturing interface produce()

---

source

Producer.produce

 Producer.produce
                   (raw_pipeline:tspace.dataflow.pipeline.deque.PipelineDQ
                   [~T_RAW], hmi_pipeline:Optional[tspace.dataflow.pipelin
                   e.queue.Pipeline[~T_HMI]]=None,
                   exit_event:Optional[threading.Event]=None)

Produce data into the pipeline

	Type	Default	Details
raw_pipeline	PipelineDQ
hmi_pipeline	Optional	None	Raw pipeline is deque to keep data fresh and ignore stale data, such as one with dict[str,str]
exit_event	Optional	None	HMI pipeline is Queue, such as one with str