Skip to main content

last

Function last 

Source
pub fn last(core: &Core, source: NodeId) -> FlowRegistration
Expand description

last(source) — buffers the latest DATA; emits Data(latest) then Complete on upstream COMPLETE. On empty stream (no DATA arrived), emits only Complete — subscribers see [Start, Complete]. For a fallback value on empty streams, use last_with_default.

Opts out of Lock 2.B auto-cascade so it can intercept upstream COMPLETE (same pattern as reduce).