ugly.rs

type ByteStream = Stream<Item = EasyBuf, Error = io::Error>;

// pub fn framed_stream<T>(s: T) -> impl T
//   where T: Stream<Item = EasyBuf, Error = io::Error>


// convert a byte stream into a stream with each chunk prefixed by a length
// marker, suitable for embedding in a bottle.
pub fn framed_stream<T>(s: T) -> stream::Flatten<
  stream::Map<T, fn(EasyBuf) -> stream::IterStream<vec::IntoIter<Result<EasyBuf, io::Error>>>>
>
  where T: Stream<Item = EasyBuf, Error = io::Error>
{
  fn frame(buffer: EasyBuf) -> stream::IterStream<vec::IntoIter<Result<EasyBuf, io::Error>>> {
    stream::iter(vec![ Ok(EasyBuf::from(zint::encode_length(buffer.len() as u32))), Ok(buffer) ])
  }
  let x = s.map(frame as fn(EasyBuf) -> stream::IterStream<vec::IntoIter<Result<EasyBuf, io::Error>>>);
  x.flatten()
}