We use flatMap to transform and filter events. stream.flatMap { x -> Observable<Foo> in do { try x.validate() guard x.isOnCertainCondition else { return .empty() } return x.fooOrNil().map(...