Skip to content

Instantly share code, notes, and snippets.

use core::future::Future;
use core::pin::Pin;
use core::task::Poll;
use futures_core::Stream;
/// Item to return from stream.
pub struct StreamItem {
pub append_length: usize,
}
/// State shared between each sequential item computation.