Class UmpTransformStream

src/ump_stream.rs:57–65

}

pub struct UmpTransformStream<S>
where
    S: Stream<Item = Result<Bytes, io::Error>> + Unpin,
{
    inner: S,
    buffer: BytesMut,
    found_stream: bool,
    remaining: usize,
}

impl<S> UmpTransformStream<S>
where