freezerasync.java

#ADD

interface Callback<T>{
	void onSuccess();
	void onError(T data);
}

userEntityManager.addAsync(List<User> users, new Callback<List<User>>{
	void onSuccess(){}
	void onError(List<User> data){}
});

#RX

Observable<List<User>> getUsersFromNetwork(...);
Observable<User> getSingleUserFromNetwork(...);

getUsersFromNetwork(...)
  		.subscribeOn(Schedulers.io())
  		.observeOn(AndroidSchedulers.mainThread())
  		.flatMap(userEntityManager::addAsync)
  		.observeOn(AndroidSchedulers.mainThread())
  		.subscribe(users -> { 
  		  	//notifyItemInserted(object);  
  		});


#SELECT

userEntityManager.select()
	.name().equalsTo("florent")
	
	.async(new Callback<List<User>>(){
		public void onResult(List<User> objects){
	
		}
	});

#RX

userEntityManager.select()
	.name().equalsTo("florent")

	.asObservable()
	.subscribeOn(Schedulers.io())
  	.observeOn(AndroidSchedulers.mainThread())

	.subscribe(new Action1<List<User>>(){
		public void call(List<User> objects){

		}
	});