TimLuq

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.