Rxjava remove query

Rxjava remove query.java

public void removeMovie(final int id) {
        Observable.fromCallable(new Func0<Integer>() {
            @Override
            public Integer call() {
                return database.delete(MyDatabaseHelper.TABLE_FAVORITES, MyDatabaseHelper.COLUMN_ID + " = " + id, null);
            }
        }).subscribeOn(Schedulers.io())
                .observeOn(Schedulers.io())
                .subscribe(new Action1<Integer>() {
                    @Override
                    public void call(Integer integer) {
                        Log.d(TAG, integer+" Deleted");
                    }
                }, new Action1<Throwable>() {
                    @Override
                    public void call(Throwable throwable) {
throwable.printStackTrace();
                    }
                });

    }