Type Definition body_image_futio::YieldBodyImage

type YieldBodyImage<B> = YieldStream<AsyncBodyImage<B>, Result<B, Error>>;

Extends AsyncBodyImage by periodically yielding.

Extends AsyncBodyImage by always yielding from Stream::poll_next (by returning Poll::Pending) immediately after it has returned Poll::Ready(Some(_)). This may be effective in some settings since the underlying AsyncBodyImage may use blocking reads (directly, without other coordination) and some use cases (e.g. Stream::fold) do not otherwise yield.

Trait Implementations

impl<B> StreamWrapper for YieldBodyImage<B> where
    B: OutputBuf, 

pub fn new(body: BodyImage, tune: FutioTunables) -> Self

Wrap by consuming the BodyImage instance.