pub type KeyValueStream = Pin<Box<dyn Stream<Item = Result<KeyValue>> + Send>>;
Stream that yields KeyValue.
struct KeyValueStream {}