考慮以下代碼：    Collection<String> foos = Arrays.asList("1", "2", "3", "X", "5", "6", "7", "8", "9", "10");    Flowable<Integer> integerFlowable = Flowable.fromIterable(foos).map(s -> Integer.parseInt(s)).onErrorReturnItem(-1);    PublishProcessor<Integer> processor = PublishProcessor.create();    processor.map(i -> 2 * i).subscribe(i -> System.out.println(i), e -> System.out.println("error!"));    integerFlowable.subscribe(processor);到達(dá)“X”時(shí)處理結(jié)束。我如何指示 RxJava 繼續(xù)處理其余的項(xiàng)目？