starting implementing streams
consuming streams