Function first 

pub fn first(core: &Core, source: NodeId) -> FlowRegistration

first(source) — emits the first DATA then Complete. Sugar for take(source, 1).