RXJAVA-filter

RXJAVA-filter

Filter 你会很常用的，它的作用也很简单，过滤器嘛。可以接受一个参数，让其过滤掉不符合我们条件的值。 package com.netty.demo.vertx; import io.reactivex.*; import io.reactivex.functions.Consumer; import io.reactivex.functions.Predicate; import lombok.extern.slf4j.Slf4j; @Slf4j public class RxJavaTest { public static void main(String[] args) throws InterruptedException { Observable.create(new ObservableOnSubscribe() { @Override public void subscribe(ObservableEmitter emitter) throws Exception { emitter.onNext(1); emitter.onNext(2); emitter.onNext(3); } }).filter(new Predicate() { @Override public boolean test(Integer o) throws Exception { return o.intValue() == 2; } }).subscribe(new Consumer() { @Override public void accept(Integer integer) throws Exception { log.info(integer.toString()); } }); Thread.sleep(300000000); } } 2021-02-23 16:57:43 [main] INFO  c.n.d.v.RxJavaTest:accept - 2

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。