pub fn flattened<S>(s: S) -> FlattenedStream<S>Expand description
Wrap a TryStream<T> whos items, TryStream::Paged.
functionally, this means a struct wrapping a Vec
in other words, a Stream of the form Stream<Item = Foo>
will instead be Stream<Item = Vec<Boo>>
ⓘ
struct Foo {
items: Vec<Boo>
}
impl Paged for Foo {
type Message = Boo;
fn messages(self) -> Vec<Boo> {
self.items
}
/* .. */
}