@Synchronized fun removeConsumed(): ConsumableStream<T>
Copies the stream but removes all consumed values.
Return a new consumable stream with the consumed values removed.