Fixed typo in consume-stream example