RxJava(2)---创建吧

上一节说到洗衣机是不同的情况下,会发出不同的音乐来通知。
那么这一节就是创建一个洗衣机和你,并且让你能够接受到洗衣机的通知

这个是你

    Subscriber<String> subscriber=new Subscriber<String>() {
        @Override
        public void onCompleted() {}
        @Override
        public void onError(Throwable e) {}
        @Override
        public void onNext(String s) {}
    };

这个是洗衣机

//基本式创建
    Observable observable=Observable.create(new Observable.OnSubscribe<String>() {
        @Override
        public void call(Subscriber<? super String> subscriber) {
            subscriber.onNext("浸泡");
            subscriber.onNext("洗衣");
            subscriber.onNext("干燥");
            subscriber.onCompleted();
        }
    });

//简洁式创建,参数是
    Observable justObservable=Observable.just("浸泡","洗衣","干燥");

//简洁式创建,参数是数组
    String[] step={"浸泡","洗衣","干燥"};
    Observable arrayObservable=Observable.from(step);

你要接听到你家洗衣机的提示

    observable.subscribe(subscriber);
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容