pollux-
07/28/2020, 7:44 PMGuillermo Alcantara
07/28/2020, 8:07 PMtableASingle.flatMap { tableBSingle }
?psh
07/28/2020, 8:10 PMqueryTableA.flatMap {
if (invalid) {
Single.error(...)
} else {
queryTableB
}
}
pollux-
07/28/2020, 8:44 PMGuillermo Alcantara
07/28/2020, 8:51 PMpollux-
07/28/2020, 11:46 PMGuillermo Alcantara
07/29/2020, 3:32 PMfilterWithError
that does that and can be reused for other streams. Where if predicate is true passes it downstream, otherwise errs.