Function take 

pub fn take<S: Clone + 'static>(n: usize) -> Operator<S>

take: emit the first n DATA values, then COMPLETE.