if you want to conditionally cause an error then u...

# rx

[jw]

if you want to conditionally cause an error then use flatMap(item -> if (logic) just(item) else error(theError))