BlockingObservable: add foreach and make it extend AnyVal