package rx3;


import io.reactivex.rxjava3.annotations.NonNull;
import io.reactivex.rxjava3.core.Flowable;
import io.reactivex.rxjava3.core.Observable;
import io.reactivex.rxjava3.core.Observer;
import io.reactivex.rxjava3.disposables.Disposable;
import io.reactivex.rxjava3.functions.Consumer;

public class Rx3Test {
 static @NonNull Consumer<? super Integer> onNextAction = new Consumer<Integer>() {
 @Override
 public void accept(Integer integer) throws Throwable {
 System.out.println("onNextAction:" + integer);
 }
 };

 public static void main(String[] args) throws InterruptedException {
// fromArray();
// reapt();
 retry();
 Thread.sleep(2000);
 }

 private static void retry() {
 Observable.range(0, 5).retry(3).subscribe(new Observer<Integer>() {
 @Override
 public void onSubscribe(@NonNull Disposable d) {

 }

 @Override
 public void onNext(@NonNull Integer integer) {
 System.out.println("onNext:" + integer);

 }

 @Override
 public void onError(@NonNull Throwable e) {

 }

 @Override
 public void onComplete() {

 }
 });

 }

 private static void reapt() {
 Observable.range(0, 5).repeat(3).subscribe(onNextAction);
 }

 //
 private static void fromArray() {
 String[] input = new String[]{
 "rxjava", "ReactiveX"
 };
 // Java 8 lambdas
 Flowable.fromArray(input).subscribe(s -> {
 System.out.println(s);
 });

 // doesn't support Java 8 lambdas (yet)
 Flowable.fromArray(input).subscribe(new Consumer<String>() {
 @Override
 public void accept(String s) throws Throwable {
 System.out.println("Hello " + s + "!");
 }
 });
 }


}