jw
repository.getEvents() .flatMap { events -> Observable.fromIterable(events).all { it.status() == Status.COMPLETED } }