pub type KadStreamSink<S, A, B> = AndThen<With<ErrInto<Framed<S, UviBytes<Cursor<Vec<u8, Global>>>>, Error>, Cursor<Vec<u8, Global>>, A, Ready<Result<Cursor<Vec<u8, Global>>, Error>>, fn(A) -> Ready<Result<Cursor<Vec<u8, Global>>, Error>>>, Ready<Result<B, Error>>, fn(BytesMut) -> Ready<Result<B, Error>>>;