simple replicate example
created a consumer wrapper
tidying stream reader