관찰 할 수있는 각 항목의 유효성 검사

Question

Observable의 각 항목의 유효성을 검사하고 조건이 실패하면 오류를 반환하는 방법은 무엇입니까?
은 지금은 내부 if와 switchMap를 사용하고 있지만,이 솔루션은 매우 좋은하지 같습니다

Observable.just(1, 2, 3, -1, 4) 
    .switchMap(x -> { 
     if (x >= 0) { 
      return Observable.just(x); 
     } else { 
      return Observable.error(new Exception("Input value should be positive")); 
     } 
    }) 
    .subscribe(
     x -> System.out.printf("value=%d\n", x), 
     err -> System.out.printf("error: %s\n", err.getMessage()) 
    ); 

내가 대신의 기본 방법을 사용할 수 있습니까?

Answer 1

doOnNext()을 사용하면 예외를 throw 할 수 있습니다.

Observable.just(1, 2, 3, -1, 4) 
     .doOnNext(x -> { 
      if (x < 0) throw Exception("Input value should be positive"); 
     }) 
     .subscribe(
      x -> System.out.printf("value=%d\n", x), 
      err -> System.out.printf("error: %s\n", err.message) 
     );