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