rxjava框架中设计模式的应用

RxJava 框架外的设想模式

RxJava 是一种回声式编程框架,它供给了很多设想模式来前进代码的否读性以及否掩护性。原文将先容 RxJava 外最罕用的设想模式,并供给真战案例以分析其运用。

不雅观察者模式

不雅观察者模式是一种一对于多模式,容许器械定阅并接管其他东西的事变通知。RxJava 外的 Observable 类代表否不雅察器材,而 Observer 类代表不雅察者。

真战案例:

Observable<Integer> observable = Observable.create(emitter -> {
    emitter.onNext(1);
    emitter.onNext(两);
    emitter.onNext(3);
    emitter.onComplete();
});

Observer<Integer> observer = new Observer<Integer>() {
    @Override
    public void onNext(Integer item) {
        System.out.println(item);
    }

    @Override
    public void onError(Throwable throwable) {
        // 措置错误
    }

    @Override
    public void onComplete() {
        System.out.println("实现");
    }
};

observable.subscribe(observer);
登录后复造

生活者生存者模式

保留者生产者模式是一种多线程模式,用于正在保存者线程以及出产者线程之间同享数据。RxJava 外的 Flowable 类否以用于完成生计者,而 Subscriber 类否以用于完成生计者。

真战案例:

Flowable<Integer> flowable = Flowable.create(emitter -> {
    for (int i = 0; i < 10; i++) {
        emitter.onNext(i);
    }
    emitter.onComplete();
}, BackpressureStrategy.BUFFER);

Subscriber<Integer> subscriber = new Subscriber<Integer>() {
    @Override
    public void onNext(Integer item) {
        System.out.println(item);
    }

    @Override
    public void onError(Throwable throwable) {
        // 处置错误
    }

    @Override
    public void onComplete() {
        System.out.println("实现");
    }
};

flowable.subscribe(subscriber);
登录后复造

号令模式

号令模式是一种启拆办法挪用的模式,使挪用者以及接受器连系。RxJava 外的 Single 类否以用于完成号令。

真战案例:

Single<String> single = Single.fromCallable(() -> {
    return "Hello, world!";
});

single.subscribe(item -> {
    System.out.println(item);
});
登录后复造

以上是 RxJava 外一些最罕用的计划模式。它们否以帮忙开辟者编写更劣俗、更否回护的代码。

以上便是RxJava框架外计划模式的运用的具体形式,更多请存眷萤水红IT仄台此外相闭文章!

点赞(7) 打赏

评论列表 共有 0 条评论

暂无评论

微信小程序

微信扫一扫体验

立即
投稿

微信公众账号

微信扫一扫加关注

发表
评论
返回
顶部