non-idematic-rx-redukt.kt

val showToast: Observable<Unit>
//...
val showToastSubject = PublishSubject.create<Unit>()
showToast = showToastSubject
val errorEffect = ObservableTransformer<Triple<State, State, Event>, Event> { upstream ->
	upstream.ofEventType<ServerResponseEvent>.switchMap { (_, _, event) →
		if (!event.isSuccessful) showToastSubject.onNext(Unit)
		Observable.empty()
	}
}