ubarua123

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
@MapKey
public @interface WorkerKey {
    Class<? extends RxWorker> value();
}

ubarua123

public static final Constraints NETWORK_CONSTRAINT = new Constraints.Builder().setRequiredNetworkType(NetworkType.CONNECTED).build();

// Create a OneTimeWorkRequest using our worker; SampleWorker.class
OneTimeWorkRequest sampleWorkRequest = new OneTimeWorkRequest
                .Builder(SampleWorker.class)
                .setConstraints(NETWORK_CONSTRAINT)
                .setBackoffCriteria(BackoffPolicy.LINEAR, OneTimeWorkRequest.DEFAULT_BACKOFF_DELAY_MILLIS, TimeUnit.MILLISECONDS)
                .build();
  
// Enqueue

ubarua123

public class SampleWorker extends RxWorker {
  
  public SampleWorker(
            @NonNull Context context,
            @NonNull WorkerParameters parameters) {
    super(context, parameters);
  }
  
  public Single<Result> createWork() {
    // Create a single observer which will hit a url and nothing else.

ubarua123

import android.annotation.TargetApi;
import android.app.Notification;
import android.app.NotificationManager;
import android.content.Context;
import android.graphics.Bitmap;
import android.net.Uri;
import android.os.Build;
import android.support.annotation.AttrRes;
import android.support.annotation.ColorInt;
import android.support.annotation.ColorRes;