Skip to content

Commit e759db6

Browse files
committed
chore(operators): update utility operators to rxjs 6+
1 parent b06c058 commit e759db6

File tree

6 files changed

+24
-26
lines changed

6 files changed

+24
-26
lines changed

operators/utility/delay.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@
1111
##### Example 1: Delay for increasing durations
1212

1313
(
14-
[StackBlitz](https://stackblitz.com/edit/typescript-gc7gct?file=index.ts&devtoolsheight=100)
14+
[StackBlitz](https://stackblitz.com/edit/typescript-twjn8r?file=index.ts&devtoolsheight=100)
1515
| [jsBin](http://jsbin.com/zebatixije/1/edit?js,console) |
1616
[jsFiddle](https://jsfiddle.net/btroncone/1kxtzcu6/) )
1717

operators/utility/delaywhen.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@
1111
##### Example 1: Delay based on observable
1212

1313
(
14-
[StackBlitz](https://stackblitz.com/edit/typescript-ydbk4j?file=index.ts&devtoolsheight=100)
14+
[StackBlitz](https://stackblitz.com/edit/typescript-5yzn8g?file=index.ts&devtoolsheight=100)
1515
| [jsBin](http://jsbin.com/topohekuje/edit?js,console) |
1616
[jsFiddle](https://jsfiddle.net/btroncone/b057mxkL/) )
1717

operators/utility/dematerialize.md

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -11,13 +11,13 @@
1111
##### Example 1: Converting notifications to values
1212

1313
(
14-
[StackBlitz](https://stackblitz.com/edit/typescript-xhldsy?file=index.ts&devtoolsheight=100)
14+
[StackBlitz](https://stackblitz.com/edit/typescript-bxdwbg?file=index.ts&devtoolsheight=100)
1515
| [jsBin](http://jsbin.com/vafedocibi/1/edit?js,console) |
1616
[jsFiddle](https://jsfiddle.net/btroncone/jw08mouy/) )
1717

1818
```js
1919
// RxJS v6+
20-
import { from, Notification } from 'rxjs/observable/from';
20+
import { from, Notification } from 'rxjs';
2121
import { dematerialize } from 'rxjs/operators';
2222

2323
//emit next and error notifications
@@ -38,7 +38,7 @@ const subscription = source.subscribe({
3838

3939
### Additional Resources
4040

41-
* [dematerialize](http://reactivex.io/rxjs/class/es6/Observable.js~Observable.html#instance-method-dematerialize)
41+
- [dematerialize](http://reactivex.io/rxjs/class/es6/Observable.js~Observable.html#instance-method-dematerialize)
4242
:newspaper: - Official docs
4343

4444
---

operators/utility/do.md

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717
##### Example 1: Logging with do
1818

1919
(
20-
[StackBlitz](https://stackblitz.com/edit/typescript-s1aymr?file=index.ts&devtoolsheight=100)
20+
[StackBlitz](https://stackblitz.com/edit/typescript-cd2gjp?file=index.ts&devtoolsheight=100)
2121
| [jsBin](http://jsbin.com/jimazuriva/1/edit?js,console) |
2222
[jsFiddle](https://jsfiddle.net/btroncone/qtyakorq/) )
2323

@@ -41,11 +41,11 @@ const subscribe = example.subscribe(val => console.log(val));
4141

4242
### Additional Resources
4343

44-
* [do](http://reactivex.io/documentation/operators/do.html)
45-
:newspaper: - Official docs
46-
* [Logging a stream with do](https://egghead.io/lessons/rxjs-logging-a-stream-with-do?course=step-by-step-async-javascript-with-rxjs)
44+
- [do](http://reactivex.io/documentation/operators/do.html) :newspaper: -
45+
Official docs
46+
- [Logging a stream with do](https://egghead.io/lessons/rxjs-logging-a-stream-with-do?course=step-by-step-async-javascript-with-rxjs)
4747
:video_camera: :dollar: - John Linquist
48-
* [Utility operator: do](https://egghead.io/lessons/rxjs-utility-operator-do?course=rxjs-beyond-the-basics-operators-in-depth)
48+
- [Utility operator: do](https://egghead.io/lessons/rxjs-utility-operator-do?course=rxjs-beyond-the-basics-operators-in-depth)
4949
:video_camera: :dollar: - André Staltz
5050

5151
---

operators/utility/timeout.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@
1111
##### Example 1: Timeout after 2.5 seconds
1212

1313
(
14-
[StackBlitz](https://stackblitz.com/edit/typescript-gl1hhr?file=index.ts&devtoolsheight=100)
14+
[StackBlitz](https://stackblitz.com/edit/typescript-eegqyz?file=index.ts&devtoolsheight=100)
1515
| [jsBin](http://jsbin.com/gonakiniho/edit?js,console) |
1616
[jsFiddle](https://jsfiddle.net/btroncone/nr4e1ofy/1/) )
1717

@@ -44,7 +44,7 @@ of(4000, 3000, 2000)
4444

4545
### Additional Resources
4646

47-
* [timeout](https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/operators/timeout.md)
47+
- [timeout](https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/operators/timeout.md)
4848
:newspaper: - Official Docs
4949

5050
---

operators/utility/topromise.md

Lines changed: 12 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,12 @@
44

55
## Convert observable to promise.
66

7+
---
8+
9+
:warning: `toPromise` has been deprecated! (RxJS 5.5+)
10+
11+
---
12+
713
<div class="ua-ad"><div class="ua-ad"><a href="https://ultimateangular.com/?ref=76683_kee7y7vk"><img src="https://ultimateangular.com/assets/img/banners/ua-leader.svg"></a></div></div>
814

915
### Examples
@@ -14,15 +20,11 @@
1420
[jsFiddle](https://jsfiddle.net/btroncone/thykc9up/) )
1521

1622
```js
17-
// RxJS v6+
18-
import { of } from 'rxjs/observable/of';
19-
import { toPromise, delay } from 'rxjs/operators';
20-
2123
//return basic observable
22-
const sample = val => of(val).pipe(delay(5000));
24+
const sample = val => Rx.Observable.of(val).delay(5000);
2325
//convert basic observable to promise
2426
const example = sample('First Example')
25-
.pipe(toPromise())
27+
.toPromise()
2628
//output: 'First Example'
2729
.then(result => {
2830
console.log('From Promise:', result);
@@ -35,20 +37,16 @@ const example = sample('First Example')
3537
[jsFiddle](https://jsfiddle.net/btroncone/xzu6u7hs/) )
3638

3739
```js
38-
// RxJS v6+
39-
import { of, delay } from 'rxjs';
40-
4140
//return basic observable
42-
const sample = val => of(val).pipe(delay(5000));
41+
const sample = val => Rx.Observable.of(val).delay(5000);
4342
/*
4443
convert each to promise and use Promise.all
4544
to wait for all to resolve
46-
(you should probably use forkJoin and no 'toPromise' instead!)
4745
*/
4846
const example = () => {
4947
return Promise.all([
50-
sample('Promise 1').pipe(toPromise()),
51-
sample('Promise 2').pipe(toPromise())
48+
sample('Promise 1').toPromise(),
49+
sample('Promise 2').toPromise()
5250
]);
5351
};
5452
//output: ["Promise 1", "Promise 2"]
@@ -59,7 +57,7 @@ example().then(val => {
5957

6058
### Additional Resources
6159

62-
* [toPromise](https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/operators/topromise.md)
60+
- [toPromise](https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/operators/topromise.md)
6361
:newspaper: - Official Docs
6462

6563
---

0 commit comments

Comments
 (0)