introduce Stream.Stopper to provide a way to terminate a stream