-
Notifications
You must be signed in to change notification settings - Fork 1
/
finalize.js
25 lines (22 loc) · 812 Bytes
/
finalize.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
const Observable = require('rxjs/Observable').Observable;
require('rxjs/add/observable/from');
const finalize = require('rxjs/operators').finalize;
Observable.from([1,2,3,4])
.pipe(
finalize(_ => {
// perhaps we can do some tear down logic here
console.log(_ + '. Finalized.');
})
)
.subscribe(console.log, console.error, _ => console.log('Complete here.')); // 1, 2, 3, 4
console.log('==============================');
Observable.create((subscriber) => {
subscriber.error('hi');
})
.pipe(
finalize(_ => {
// perhaps we can do some tear down logic here
console.log(_ + '. Error Finalized.');
})
)
.subscribe(console.log, console.error, _ => console.log('Error complete here.')); // 1, 2, 3, 4