Room with RxJava Example

UserDao.kt

@Dao
interface UserDao {
    @Query("SELECT * from users where uid = :id LIMIT 1")
    fun loadUserById(id: Int): Flowable<User>
    @Insert
    fun insertUsers(vararg users: User): Completable
    @Delete
    fun deleteAllUsers(users: List<User>): Single<Int>
}