У меня есть запрос к базе данных моей комнаты:
@Query("SELECT * FROM $TABLE WHERE $ID = :id")
fun getStuff(id: String): Flowable<Foo>
Я заполняю свой экран результатами этого запроса, оставляя соединение открытым с этим Flowable для id, связанным с этим экран. Это хорошо работает, потому что я автоматически получаю обновления БД.
В моем приложении существует поток пользователей, где строка с id может быть удалена из моей базы данных, пока я все еще на экране для id .
Как я могу получить Flowable от getStuff для выдачи некоторого уведомления о том, что строка была удалена?