Skip to content

Instantly share code, notes, and snippets.

@kombadzomba
Created September 16, 2016 21:18
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save kombadzomba/0d7722d71fbd93d65efe3ea59cdb3654 to your computer and use it in GitHub Desktop.
Save kombadzomba/0d7722d71fbd93d65efe3ea59cdb3654 to your computer and use it in GitHub Desktop.
public static void warmpupSearch() {
Observable observable = Observable.create(new Observable.OnSubscribe<LinkedList<TerminEntity>>() {
@Override
public void call(Subscriber<? super LinkedList<TerminEntity>> subscriber) {
try {
subscriber.onNext(CouchDbFacade.getInstance().getTerminByDateAndClientName(
null,
null,
null,
null));
subscriber.onCompleted();
} catch (Exception e) {
LogUtil.reportToDevelopers(e);
subscriber.onError(e);
}
}
});
observable
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Subscriber<LinkedList<TerminEntity>>() {
@Override
public void onCompleted() {
// do nothing
}
@Override
public void onError(Throwable e) {
Log.d(TAG, "Rx error: " + e.getMessage());
// do nothing
}
@Override
public void onNext(LinkedList<TerminEntity> result) {
// do nothing
}
});
}
public static void warmpupServicesActiveAll() {
Observable observable = Observable.create(new Observable.OnSubscribe<LinkedList<ServiceEntity>>() {
@Override
public void call(Subscriber<? super LinkedList<ServiceEntity>> subscriber) {
try {
subscriber.onNext(CouchDbFacade.getInstance().getServicesActiveAll());
subscriber.onCompleted();
} catch (Exception e) {
LogUtil.reportToDevelopers(e);
subscriber.onError(e);
}
}
});
observable
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Subscriber<LinkedList<ServiceEntity>>() {
@Override
public void onCompleted() {
// do nothing
}
@Override
public void onError(Throwable e) {
Log.d(TAG, "Rx error: " + e.getMessage());
// do nothing
}
@Override
public void onNext(LinkedList<ServiceEntity> result) {
// do nothing
}
});
}
public static void warmpupServiceById() {
Observable observable = Observable.create(new Observable.OnSubscribe<ServiceEntity>() {
@Override
public void call(Subscriber<? super ServiceEntity> subscriber) {
try {
subscriber.onNext(CouchDbFacade.getInstance().getServiceById(null));
subscriber.onCompleted();
} catch (Exception e) {
LogUtil.reportToDevelopers(e);
subscriber.onError(e);
}
}
});
observable
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Subscriber<ServiceEntity>() {
@Override
public void onCompleted() {
// do nothing
}
@Override
public void onError(Throwable e) {
Log.d(TAG, "Rx error: " + e.getMessage());
// do nothing
}
@Override
public void onNext(ServiceEntity result) {
// do nothing
}
});
}
public static void warmpupStaffAll() {
Observable observable = Observable.create(new Observable.OnSubscribe<LinkedList<StaffEntity>>() {
@Override
public void call(Subscriber<? super LinkedList<StaffEntity>> subscriber) {
try {
subscriber.onNext(CouchDbFacade.getInstance().getStaffAll());
subscriber.onCompleted();
} catch (Exception e) {
LogUtil.reportToDevelopers(e);
subscriber.onError(e);
}
}
});
observable
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Subscriber<LinkedList<StaffEntity>>() {
@Override
public void onCompleted() {
// do nothing
}
@Override
public void onError(Throwable e) {
Log.d(TAG, "Rx error: " + e.getMessage());
// do nothing
}
@Override
public void onNext(LinkedList<StaffEntity> result) {
// do nothing
}
});
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment