Add dagger named annotations to RequeryRepository base class
This commit is contained in:
parent
855d1be3fd
commit
a07f12d63b
|
@ -1,5 +1,9 @@
|
||||||
package org.mercury_im.messenger.data.repository;
|
package org.mercury_im.messenger.data.repository;
|
||||||
|
|
||||||
|
import org.mercury_im.messenger.util.ThreadUtils;
|
||||||
|
|
||||||
|
import javax.inject.Named;
|
||||||
|
|
||||||
import io.reactivex.Scheduler;
|
import io.reactivex.Scheduler;
|
||||||
import io.requery.Persistable;
|
import io.requery.Persistable;
|
||||||
import io.requery.reactivex.ReactiveEntityStore;
|
import io.requery.reactivex.ReactiveEntityStore;
|
||||||
|
@ -12,8 +16,8 @@ public abstract class RequeryRepository {
|
||||||
private final ReactiveEntityStore<Persistable> data;
|
private final ReactiveEntityStore<Persistable> data;
|
||||||
|
|
||||||
protected RequeryRepository(ReactiveEntityStore<Persistable> data,
|
protected RequeryRepository(ReactiveEntityStore<Persistable> data,
|
||||||
Scheduler subscriberScheduler,
|
@Named(value = ThreadUtils.SCHEDULER_IO) Scheduler subscriberScheduler,
|
||||||
Scheduler observerScheduler) {
|
@Named(value = ThreadUtils.SCHEDULER_UI) Scheduler observerScheduler) {
|
||||||
this.data = data;
|
this.data = data;
|
||||||
this.subscriberScheduler = subscriberScheduler;
|
this.subscriberScheduler = subscriberScheduler;
|
||||||
this.observerScheduler = observerScheduler;
|
this.observerScheduler = observerScheduler;
|
||||||
|
|
Loading…
Reference in New Issue