tachiyomi/app/src/main/java/eu/kanade/mangafeed/data/models/Page.java

package eu.kanade.mangafeed.data.models;

import eu.kanade.mangafeed.data.helpers.NetworkHelper;
import rx.subjects.BehaviorSubject;

public class Page implements NetworkHelper.ProgressListener {

    private int pageNumber;
    private String url;
    private String imageUrl;
    private String imagePath;
    private transient volatile int status;
    private transient volatile int progress;

    private transient BehaviorSubject<Integer> statusSubject;

    public static final int QUEUE = 0;
    public static final int LOAD_PAGE = 1;
    public static final int DOWNLOAD_IMAGE = 2;
    public static final int READY = 3;
    public static final int ERROR = 4;

    public Page(int pageNumber, String url, String imageUrl, String imagePath) {
        this.pageNumber = pageNumber;
        this.url = url;
        this.imageUrl = imageUrl;
        this.imagePath = imagePath;
    }

    public Page(int pageNumber, String url) {
        this(pageNumber, url, null, null);
    }

    public int getPageNumber() {
        return pageNumber;
    }

    public String getUrl() {
        return url;
    }

    public String getImageUrl() {
        return imageUrl;
    }

    public void setImageUrl(String imageUrl) {
        this.imageUrl = imageUrl;
    }

    public String getImagePath() {
        return imagePath;
    }

    public void setImagePath(String imagePath) {
        this.imagePath = imagePath;
    }

    public int getStatus() {
        return status;
    }

    public void setStatus(int status) {
        this.status = status;
        notifyStatus();
    }

    public int getProgress() {
        return progress;
    }

    @Override
    public void update(long bytesRead, long contentLength, boolean done) {
        progress = (int) ((100 * bytesRead) / contentLength);
    }

    public void setStatusSubject(BehaviorSubject<Integer> subject) {
        this.statusSubject = subject;
        notifyStatus();
    }

    private void notifyStatus() {
        if (statusSubject != null)
            statusSubject.onNext(status);
    }

}