Observable创建的方式Rxjs库已经内置支持了很多操作符,所以我们只需要理解并使用即可
1、create
从任何形式创建一个Observable,静态方法,可以直接使用。
1 |
|
2 | const myObservable = Observable.create((observer) => { |
3 | observer.next('Vivian'); |
4 | observer.next('Jeanne'); |
5 | setTimeout(() => { |
6 | observer.next('====create rxjs!'); |
7 | }, 2000); |
8 | observer.complete(); |
9 | observer.next('not work ?'); |
10 | }); |
11 |
|
12 |
|
13 | console.log('===1====start'); |
14 | myObservable.subscribe(value => { |
15 | console.log('1. 创建Observable: ', value); |
16 | }); |
17 | console.log('===1====end'); |
18 |
|
19 |
|
20 | const innerObserver = { |
21 | next: (value) => { console.log('2. 创建Observable: ', value); }, |
22 | error: (error) => { console.log('2. 创建Observable--Error', error); }, |
23 | complete: () => { console.log('2.创建Observable: complete'); } |
24 | }; |
25 | console.log('===2====start'); |
26 | myObservable.subscribe(innerObserver); |
27 | console.log('===2====end'); |