you don't need a subject, you just need an Observa...

# rx

[jw]

you don't need a subject, you just need an Observable that emits when the database should be queried and then flatMap on the query