fix(core): Fix random failures in RxStorageBindingTest (#2986)

Author: mattcreaser

rxbindings/src/test/java/com/amplifyframework/rx/RxStorageBindingTest.java

@@ -242,7 +242,7 @@ public void downloadFileReturnsResult() throws InterruptedException {
             Consumer<StorageTransferProgress> progressConsumer = invocation.getArgument(indexOfProgressConsumer);
             Consumer<StorageDownloadFileResult> resultConsumer = invocation.getArgument(indexOfResultConsumer);
 
-            Observable.interval(100, 100, TimeUnit.MILLISECONDS)
+            Observable.interval(250, 100, TimeUnit.MILLISECONDS)
                       .take(5)
                       .doOnNext(aLong -> progressConsumer.accept(new StorageTransferProgress(aLong, 500)))
                       .doOnComplete(() -> resultConsumer.accept(result))
@@ -282,7 +282,7 @@ public void downloadFileStoragePathReturnsResult() throws InterruptedException {
             Consumer<StorageTransferProgress> progressConsumer = invocation.getArgument(indexOfProgressConsumer);
             Consumer<StorageDownloadFileResult> resultConsumer = invocation.getArgument(indexOfResultConsumer);
 
-            Observable.interval(100, 100, TimeUnit.MILLISECONDS)
+            Observable.interval(250, 100, TimeUnit.MILLISECONDS)
                     .take(5)
                     .doOnNext(aLong -> progressConsumer.accept(new StorageTransferProgress(aLong, 500)))
                     .doOnComplete(() -> resultConsumer.accept(result))
@@ -409,7 +409,7 @@ public void uploadFileReturnsResult() throws InterruptedException {
             Consumer<StorageUploadFileResult> resultConsumer = invocation.getArgument(indexOfResultConsumer);
             Consumer<StorageTransferProgress> progressConsumer = invocation.getArgument(indexOfProgressConsumer);
 
-            Observable.interval(100, 100, TimeUnit.MILLISECONDS)
+            Observable.interval(250, 100, TimeUnit.MILLISECONDS)
                       .take(5)
                       .doOnNext(aLong -> progressConsumer.accept(new StorageTransferProgress(aLong, 500)))
                       .doOnComplete(() -> resultConsumer.accept(result))
@@ -448,7 +448,7 @@ public void uploadFileStoragePathReturnsResult() throws InterruptedException {
             Consumer<StorageUploadFileResult> resultConsumer = invocation.getArgument(indexOfResultConsumer);
             Consumer<StorageTransferProgress> progressConsumer = invocation.getArgument(indexOfProgressConsumer);
 
-            Observable.interval(100, 100, TimeUnit.MILLISECONDS)
+            Observable.interval(250, 100, TimeUnit.MILLISECONDS)
                     .take(5)
                     .doOnNext(aLong -> progressConsumer.accept(new StorageTransferProgress(aLong, 500)))
                     .doOnComplete(() -> resultConsumer.accept(result))
@@ -520,7 +520,7 @@ public void uploadInputStreamReturnsResult() throws InterruptedException {
             Consumer<StorageUploadInputStreamResult> resultConsumer = invocation.getArgument(indexOfResultConsumer);
             Consumer<StorageTransferProgress> progressConsumer = invocation.getArgument(indexOfProgressConsumer);
 
-            Observable.interval(100, 100, TimeUnit.MILLISECONDS)
+            Observable.interval(250, 100, TimeUnit.MILLISECONDS)
                     .take(5)
                     .doOnNext(aLong -> progressConsumer.accept(new StorageTransferProgress(aLong, 500)))
                     .doOnComplete(() -> resultConsumer.accept(result))
@@ -563,7 +563,7 @@ public void uploadInputStreamStoragePathReturnsResult() throws InterruptedExcept
             Consumer<StorageUploadInputStreamResult> resultConsumer = invocation.getArgument(indexOfResultConsumer);
             Consumer<StorageTransferProgress> progressConsumer = invocation.getArgument(indexOfProgressConsumer);
 
-            Observable.interval(100, 100, TimeUnit.MILLISECONDS)
+            Observable.interval(250, 100, TimeUnit.MILLISECONDS)
                     .take(5)
                     .doOnNext(aLong -> progressConsumer.accept(new StorageTransferProgress(aLong, 500)))
                     .doOnComplete(() -> resultConsumer.accept(result))