Struct SourcePump 

pub struct SourcePump { /* private fields */ }

Owns a source’s spawned reader task and aborts it on drop. Holds the pump+abort lifecycle so a transport author never re-derives it (the source-emit ruling — see the module docs / PROCESSOR-DESIGN §10 Q6).

Implementations

impl SourcePump

pub fn spawn<F, Fut>(head: UnboundedSender<Frame>, f: F) -> Self

where F: FnOnce(SourceHandle) -> Fut + Send + 'static, Fut: Future<Output = ()> + Send + 'static,

Spawn a source reader. f receives a SourceHandle and runs the transport’s recv() loop, emiting frames into the pipeline head until the transport is exhausted (then it should call SourceHandle::end). The returned SourcePump aborts the reader on drop, so dropping it after PipelineTask::run returns cleans the reader up.

pub fn from_handle(handle: JoinHandle<()>) -> Self

Wrap an already-spawned reader handle (for sources that build their own task — e.g. one that needs the JoinHandle before the loop body). The reader is still expected to feed the head via a SourceHandle.

pub fn abort(&self)

Stop the reader task immediately (used after run() returns).

Trait Implementations

impl Drop for SourcePump

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.