Update ConsumeStream.java