Struct Tee 

pub struct Tee { /* private fields */ }

Fans a single input out to multiple sinks. TeeBuilder owns the initial fan-out; later branches are added and removed through a TeeHandle, which can be cloned and used from any thread, independent of whatever thread is driving Tee::consume (the pipeline’s source/queue-worker thread). That’s the whole reason Tee doesn’t implement crate::element::Source like other multi-pad elements (e.g. crate::elements::FileDemuxer): its pads live in individually locked branch slots instead of being a plain &mut [SrcPad]. consume only holds the branch-list lock long enough to take a cheap Arc snapshot, so a slow downstream does not block unrelated attach/detach operations. Detach prevents any push that has not started yet; one already executing downstream call may finish.

Cheap to fan out: MediaBuffer wraps its payload in an Arc, so cloning a buffer for each output is a refcount bump, not a copy of the encoded/decoded data.

Trait Implementations

impl Element for Tee

fn name(&self) -> Arc<str>

Returns a cheap clone (refcount bump, not a deep copy) of this element’s name — crate::bus::BusEvent stores names as Arc<str> for exactly this reason: a hot path like crate::queue::Queue posting BusEvent::Dropped once per overflowed buffer shouldn’t pay for a fresh heap allocation every time it wants to report which element it is.

fn element_type(&self) -> ElementType

See ElementType.

fn graph_id(&self) -> Option<ElementId>

A pre-reserved graph identity for elements that expose dynamic attachment handles. Most elements receive an ID from ChainBuilder and keep the default None implementation.

fn pp_log(&self) -> &PpLog

This element’s identity for crate::bus::Bus::post — same id/name as Element::name, just already wrapped as the crate::pp_log::PpLog its pp_info!/pp_warn!/pp_error! macros need. A stored private field, not built fresh per call, for the same reason name() returns a cheap Arc<str> clone instead of a fresh String — see its own docs.

fn pp_log_mut(&mut self) -> &mut PpLog

Mutable access to the same field Element::pp_log reads — used by crate::pipeline::ChainBuilder to stamp the owning crate::pipeline::Pipeline’s id onto every element that passes through it, via element_pp_log. Not meant to be called from anywhere else.

impl Sink for Tee

fn consume(&mut self, buf: MediaBuffer) -> Result<()>

fn control(&mut self, msg: ControlMsg) -> Result<()>

Reacts to a ControlMsg (pause/resume/stop) and, for anything with a downstream of its own, forwards it on — same shape as consume, just a separate channel from MediaBuffer so it can reach every element (not just ones that already know how to interpret a data buffer) and, at a crate::queue::Queue, jump ahead of whatever data is backed up instead of waiting behind it. No default: every Sink has to consciously decide what this means for it, rather than silently dropping it.