Consume a stream until a given pattern is found - View it on GitHub