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