Daos
==============================================================================================================
@Query("SELECT * FROM Message")
Observable<List<Entities.Message>> getAllMessages();

@Insert
void insertMessage(Entities.Message message);
==============================================================================================================

Чтение
==============================================================================================================
databaseDisposable = DatabaseHelper.getDatabase(this).messageDao().getAllMessages()
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Consumer<List<Entities.Message>>() {
                    @Override
                    public void accept(List<Entities.Message> messages) throws Exception {
                        for (Entities.Message message : messages)
                            logMessage(message);
                    }
                });
==============================================================================================================

Запись
==============================================================================================================
Completable.fromAction(new Action() {
            @Override
            public void run() throws Exception {
                database.messageDao().insertMessage(message);
            }
                })
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new CompletableObserver() {
            @Override
            public void onSubscribe(Disposable d) {
                Log.e(TAG, "Subscribe");
            }

            @Override
            public void onComplete() {
                Log.e(TAG, "Writing complete");
            }

            @Override
            public void onError(Throwable e) {
                Log.e(TAG, "ERROR");
            }
        });
    }
==============================================================================================================