parahall

public class MainViewModel extends AndroidViewModel {

  private LiveData<List<StarWarsMovie>> moviesLiveData;
  @Inject AppDatabase mDb;

  public MainViewModel(Application application) {
    super(application);
    ((StarWarsApplication) getApplication()).getAppComponent().inject(this);
    requestDataUpdates();

parahall

public class StarWarsService extends IntentService {

  @Inject AppDatabase db;

  public StarWarsService() {
    super("StarWarsService");
  }

  @Override public void onCreate() {
    super.onCreate();

parahall

public abstract class BasePresenter<T extends MvpView> {
  HandlerThread thread;
  Looper looper;
  Handler handler;

  private T mView;

  public BasePresenter() {

  }

parahall

public class NetworkHttpUnauthorizedReceiver extends BroadcastReceiver {

  public void onReceive(Context context, Intent intent) {
    int httpCode = intent.getIntExtra(IntentExtras.HTTP_CODE, -1);
    if (httpCode == HttpURLConnection.HTTP_UNAUTHORIZED) {
      LoginActivity.logOut(context);
    }
  }
}

parahall

Job myJob = firebaseJobDispatcher.newJobBuilder()
 .setService(SmartService.class)
 .setTag(SmartService.LOCATION_SMART_JOB)
 .setReplaceCurrent(false)
 .setConstraints(ON_ANY_NETWORK)
 .build();
firebaseJobDispatcher.mustSchedule(myJob);

parahall

@Override
public WorkerResult doWork() {
    ...
    LocalBroadcastManager.getInstance(getAppContext()).registerReceiver(receiver, new IntentFilter(LocationBaseBroadcast.ACTION_NEW_LOCATION_ARRIVED));
    locationTracker.start();
    try {
        locationWait = new CountDownLatch(1);
        locationWait.await();
    } catch (InterruptedException e) {

parahall

public class LocationWork extends Worker {

    ...
  
    static void reportFinished() {
        if (locationWait != null) {
            Log.d(TAG, "doWork: locationWait down by one");
            locationWait.countDown();
        }
    }

parahall

//location obtained, need to send it to server
    private void broadcastLocation(Location location) {
        //release latch
        reportFinished();
        //We need to sure that device have internet live
        Constraints constraints = new Constraints.Builder().setRequiredNetworkType
                (NetworkType.CONNECTED).build();
        
        //Parse our location to Data to use it as input for our worker
        Data inputData = new Data.Builder()

parahall

public class LocationUploadWorker extends Worker {
    //...
  
    public WorkerResult doWork() {
      //get Data out from input
        double longitude = getInputData().getDouble(LOCATION_LONG, 0);
        double latitude = getInputData().getDouble(LOCATION_LAT, 0);
        long time = getInputData().getLong(LOCATION_TIME, 0);
        String osVersion = "WorkerReport v" + Build.VERSION.SDK_INT;
        //construct our report for server format

parahall

int threads = Runtime.getRuntime().availableProcessors();
ExecutorService executor = Executors.newFixedThreadPool(threads);
executor.submit(myWork);