Skip to content
This repository was archived by the owner on Apr 20, 2018. It is now read-only.

Commit 7d7a09f

Browse files
Updating to latest version
1 parent 51d78c7 commit 7d7a09f

12 files changed

Lines changed: 1045 additions & 719 deletions

File tree

src/modular/dist/rx.all.js

Lines changed: 401 additions & 332 deletions
Large diffs are not rendered by default.

src/modular/dist/rx.all.min.js

Lines changed: 5 additions & 5 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

src/modular/dist/rx.js

Lines changed: 197 additions & 128 deletions
Large diffs are not rendered by default.

src/modular/dist/rx.lite.js

Lines changed: 366 additions & 248 deletions
Large diffs are not rendered by default.

src/modular/dist/rx.lite.min.js

Lines changed: 3 additions & 2 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

src/modular/dist/rx.min.js

Lines changed: 3 additions & 3 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

src/modular/index.js

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -71,6 +71,7 @@ Observable.addToPrototype({
7171
dematerialize: require('./observable/dematerialize'),
7272
distinct: require('./observable/distinct'),
7373
distinctUntilChanged: require('./observable/distinctuntilchanged'),
74+
do: require('./observable/tap'),
7475
every: require('./observable/every'),
7576
filter: require('./observable/filter'),
7677
finally: require('./observable/finally'),
@@ -144,6 +145,7 @@ Observable.addToPrototype({
144145
timestamp: require('./observable/timestamp'),
145146
toArray: require('./observable/toarray'),
146147
toMap: require('./observable/tomap'),
148+
toPromise: require('./observable/topromise'),
147149
toSet: require('./observable/toset'),
148150
transduce: require('./observable/transduce'),
149151
window: require('./observable/window'),
Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,14 @@
1+
'use strict';
2+
3+
module.exports = function toPromise(source, promiseCtor) {
4+
promiseCtor || (promiseCtor = global.Promise);
5+
return new promiseCtor(function (resolve, reject) {
6+
// No cancellation can be done
7+
var value;
8+
source.subscribe(function (v) {
9+
value = v;
10+
}, reject, function () {
11+
resolve(value);
12+
});
13+
});
14+
};

src/modular/package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "@rxjs/rx",
3-
"version": "4.0.10",
3+
"version": "4.0.11",
44
"description": "The Reactive Extensions for JavaScript",
55
"main": "index.js",
66
"scripts": {

src/modular/rx.js

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -43,6 +43,7 @@ Observable.addToPrototype({
4343
concat: require('./observable/concat'),
4444
concatAll: require('./observable/concatall'),
4545
distinctUntilChanged: require('./observable/distinctuntilchanged'),
46+
do: require('./observable/tap'),
4647
filter: require('./observable/filter'),
4748
finally: require('./observable/finally'),
4849
flatMap: require('./observable/flatmap'),
@@ -59,6 +60,7 @@ Observable.addToPrototype({
5960
takeUntil: require('./observable/takeuntil'),
6061
tap: require('./observable/tap'),
6162
toArray: require('./observable/toarray'),
63+
toPromise: require('./observable/topromise'),
6264
zip: require('./observable/zip')
6365
});
6466

0 commit comments

Comments
 (0)