transformer.kt

val transformer = store.publish { upstream →
	Observable.merge(
		upstream.ofEventType<NameChangeEvent>.switchMap { (_, state, _) →
			api.validate(state.name)
		}
			.map { apiResult → ValidationResult(…) },
		upstream.ofEventType<OtherEvent>.map { …. }
	)
}