openc2_consumer 0.2.0

Rust types for OpenC2 consumers
Documentation
1
2
3
4
5
6
7
8
9
10
11
12
use futures::{
    StreamExt, future,
    stream::{self, BoxStream},
};

/// Returns a [`BoxStream`] containing a single ready value.
pub fn stream_just<T>(item: T) -> BoxStream<'static, T>
where
    T: Send + 'static,
{
    stream::once(future::ready(item)).boxed()
}