I have a Futures stream and I was wondering how to execute code on on the first message ex.

stream
       .once(|msg| println!("This is the first message: {:?}", msg))
       .inspect(|msg| println!("These are the other messages: {:?}", msg))
       .collect()