Replace int with long for downloaded/uploaded amount

src/main/java/jtorrent/domain/torrent/model/Torrent.java

@@ -253,7 +253,7 @@ public Observable<Double> getDownloadRateObservable() {
         return downloadRateObservable;
     }
 
-    public Observable<Integer> getDownloadedObservable() {
+    public Observable<Long> getDownloadedObservable() {
         return torrentStatistics.getDownloadedObservable();
     }
 
@@ -267,7 +267,7 @@ public Observable<Double> getUploadRateObservable() {
         return uploadRateObservable;
     }
 
-    public Observable<Integer> getUploadedObservable() {
+    public Observable<Long> getUploadedObservable() {
         return torrentStatistics.getUploadedObservable();
     }
 

src/main/java/jtorrent/domain/torrent/model/TorrentStatistics.java

@@ -1,19 +1,19 @@
 package jtorrent.domain.torrent.model;
 
-import java.util.concurrent.atomic.AtomicInteger;
+import java.util.concurrent.atomic.AtomicLong;
 
 import io.reactivex.rxjava3.core.Observable;
 import io.reactivex.rxjava3.subjects.BehaviorSubject;
 
 public class TorrentStatistics {
 
-    private final AtomicInteger downloaded = new AtomicInteger(0);
-    private final BehaviorSubject<Integer> downloadedSubject = BehaviorSubject.createDefault(0);
+    private final AtomicLong downloaded = new AtomicLong(0);
+    private final BehaviorSubject<Long> downloadedSubject = BehaviorSubject.createDefault(0L);
 
-    private final AtomicInteger uploaded = new AtomicInteger(0);
-    private final BehaviorSubject<Integer> uploadedSubject = BehaviorSubject.createDefault(0);
+    private final AtomicLong uploaded = new AtomicLong(0);
+    private final BehaviorSubject<Long> uploadedSubject = BehaviorSubject.createDefault(0L);
 
-    public void incrementDownloaded(int bytes) {
+    public void incrementDownloaded(long bytes) {
         downloadedSubject.onNext(downloaded.addAndGet(bytes));
     }
 
@@ -25,15 +25,15 @@ public long getDownloaded() {
         return downloaded.get();
     }
 
-    public Observable<Integer> getDownloadedObservable() {
+    public Observable<Long> getDownloadedObservable() {
         return downloadedSubject;
     }
 
     public long getUploaded() {
         return uploaded.get();
     }
 
-    public Observable<Integer> getUploadedObservable() {
+    public Observable<Long> getUploadedObservable() {
         return uploadedSubject;
     }
 }