[−][src]Function tokio_stream::once
pub fn once<T>(value: T) -> Once<T>
Creates a stream that emits an element exactly once.
The returned stream is immediately ready and emits the provided value once.
Examples
use tokio_stream::{self as stream, StreamExt}; #[tokio::main] async fn main() { // one is the loneliest number let mut one = stream::once(1); assert_eq!(Some(1), one.next().await); // just one, that's all we get assert_eq!(None, one.next().await); }