use futures::{stream, prelude::*};

fn main() {
    let tweet_stream = stream::empty::<Tweet, ()>();

    tweet_stream.map(|tweet| {
         let parts = to_parts(&tweet.text);
        (tweet, parts)
    });
}

pub fn to_parts(string: &str) -> Vec<Part> {
    string.split(' ').map(|s| Part::Word(s)).collect()
}

#[derive(Debug, PartialEq)]
pub enum Part<'a> {
    Word(&'a str),
    Whitespace(&'a str),
}

pub struct Tweet {
    pub id: String,
    pub text: String
}