Observable各アイテムの有効性を確認

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()を使用して例外をスローすることができます。

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) 
     );