rxjs-marbles - npm Package Compare versions

Comparing version 5.0.3 to 5.0.4

bundles/rxjs-marbles-jasmine.umd.js

@@ -182,2 +182,14 @@ (function webpackUniversalModuleDefinition(root, factory) {
 
+/***/ "./source/done-subscriber.ts":
+/*!***********************************!*\
+  !*** ./source/done-subscriber.ts ***!
+  \***********************************/
+/*! no static exports found */
+/***/ (function(module, exports, __webpack_require__) {
+
+"use strict";
+eval("\r\nvar __extends = (this && this.__extends) || (function () {\r\n    var extendStatics = function (d, b) {\r\n        extendStatics = Object.setPrototypeOf ||\r\n            ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||\r\n            function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };\r\n        return extendStatics(d, b);\r\n    };\r\n    return function (d, b) {\r\n        extendStatics(d, b);\r\n        function __() { this.constructor = d; }\r\n        d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());\r\n    };\r\n})();\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar rxjs_1 = __webpack_require__(/*! rxjs */ \"rxjs\");\r\nvar DoneSubscriber = (function (_super) {\r\n    __extends(DoneSubscriber, _super);\r\n    function DoneSubscriber(onError, onComplete) {\r\n        var _this = _super.call(this, undefined, onError, onComplete) || this;\r\n        _this.onError = onError;\r\n        return _this;\r\n    }\r\n    DoneSubscriber.prototype.unsubscribe = function () {\r\n        try {\r\n            _super.prototype.unsubscribe.call(this);\r\n        }\r\n        catch (error) {\r\n            this.onError(error);\r\n        }\r\n    };\r\n    return DoneSubscriber;\r\n}(rxjs_1.Subscriber));\r\nexports.DoneSubscriber = DoneSubscriber;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/done-subscriber.ts?");
+
+/***/ }),
+
 /***/ "./source/expect.ts":
@@ -227,3 +239,3 @@ /*!**************************!*\
 "use strict";
-eval("\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nfunction observe(observableTest) {\r\n    return function (done) {\r\n        return observableTest().subscribe(undefined, done.fail, done);\r\n    };\r\n}\r\nexports.observe = observe;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/jasmine/observe.ts?");
+eval("\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar done_subscriber_1 = __webpack_require__(/*! ../done-subscriber */ \"./source/done-subscriber.ts\");\r\nfunction observe(observableTest) {\r\n    return function (done) {\r\n        var subscriber = new done_subscriber_1.DoneSubscriber(done.fail, done);\r\n        observableTest().subscribe(subscriber);\r\n    };\r\n}\r\nexports.observe = observe;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/jasmine/observe.ts?");
 
@@ -230,0 +242,0 @@ /***/ }),

bundles/rxjs-marbles-jest.umd.js

@@ -182,2 +182,14 @@ (function webpackUniversalModuleDefinition(root, factory) {
 
+/***/ "./source/done-subscriber.ts":
+/*!***********************************!*\
+  !*** ./source/done-subscriber.ts ***!
+  \***********************************/
+/*! no static exports found */
+/***/ (function(module, exports, __webpack_require__) {
+
+"use strict";
+eval("\r\nvar __extends = (this && this.__extends) || (function () {\r\n    var extendStatics = function (d, b) {\r\n        extendStatics = Object.setPrototypeOf ||\r\n            ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||\r\n            function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };\r\n        return extendStatics(d, b);\r\n    };\r\n    return function (d, b) {\r\n        extendStatics(d, b);\r\n        function __() { this.constructor = d; }\r\n        d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());\r\n    };\r\n})();\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar rxjs_1 = __webpack_require__(/*! rxjs */ \"rxjs\");\r\nvar DoneSubscriber = (function (_super) {\r\n    __extends(DoneSubscriber, _super);\r\n    function DoneSubscriber(onError, onComplete) {\r\n        var _this = _super.call(this, undefined, onError, onComplete) || this;\r\n        _this.onError = onError;\r\n        return _this;\r\n    }\r\n    DoneSubscriber.prototype.unsubscribe = function () {\r\n        try {\r\n            _super.prototype.unsubscribe.call(this);\r\n        }\r\n        catch (error) {\r\n            this.onError(error);\r\n        }\r\n    };\r\n    return DoneSubscriber;\r\n}(rxjs_1.Subscriber));\r\nexports.DoneSubscriber = DoneSubscriber;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/done-subscriber.ts?");
+
+/***/ }),
+
 /***/ "./source/expect.ts":
@@ -239,3 +251,3 @@ /*!**************************!*\
 "use strict";
-eval("\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nfunction observe(observableTest) {\r\n    return function (done) {\r\n        return observableTest().subscribe(undefined, done.fail, done);\r\n    };\r\n}\r\nexports.observe = observe;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/jest/observe.ts?");
+eval("\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar done_subscriber_1 = __webpack_require__(/*! ../done-subscriber */ \"./source/done-subscriber.ts\");\r\nfunction observe(observableTest) {\r\n    return function (done) {\r\n        var subscriber = new done_subscriber_1.DoneSubscriber(done.fail, done);\r\n        observableTest().subscribe(subscriber);\r\n    };\r\n}\r\nexports.observe = observe;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/jest/observe.ts?");
 
@@ -242,0 +254,0 @@ /***/ }),

bundles/rxjs-marbles-mocha.umd.js

@@ -182,2 +182,14 @@ (function webpackUniversalModuleDefinition(root, factory) {
 
+/***/ "./source/done-subscriber.ts":
+/*!***********************************!*\
+  !*** ./source/done-subscriber.ts ***!
+  \***********************************/
+/*! no static exports found */
+/***/ (function(module, exports, __webpack_require__) {
+
+"use strict";
+eval("\r\nvar __extends = (this && this.__extends) || (function () {\r\n    var extendStatics = function (d, b) {\r\n        extendStatics = Object.setPrototypeOf ||\r\n            ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||\r\n            function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };\r\n        return extendStatics(d, b);\r\n    };\r\n    return function (d, b) {\r\n        extendStatics(d, b);\r\n        function __() { this.constructor = d; }\r\n        d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());\r\n    };\r\n})();\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar rxjs_1 = __webpack_require__(/*! rxjs */ \"rxjs\");\r\nvar DoneSubscriber = (function (_super) {\r\n    __extends(DoneSubscriber, _super);\r\n    function DoneSubscriber(onError, onComplete) {\r\n        var _this = _super.call(this, undefined, onError, onComplete) || this;\r\n        _this.onError = onError;\r\n        return _this;\r\n    }\r\n    DoneSubscriber.prototype.unsubscribe = function () {\r\n        try {\r\n            _super.prototype.unsubscribe.call(this);\r\n        }\r\n        catch (error) {\r\n            this.onError(error);\r\n        }\r\n    };\r\n    return DoneSubscriber;\r\n}(rxjs_1.Subscriber));\r\nexports.DoneSubscriber = DoneSubscriber;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/done-subscriber.ts?");
+
+/***/ }),
+
 /***/ "./source/expect.ts":
@@ -251,3 +263,3 @@ /*!**************************!*\
 "use strict";
-eval("\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nfunction observe(observableTest) {\r\n    return function (done) {\r\n        return observableTest().subscribe(undefined, done, done);\r\n    };\r\n}\r\nexports.observe = observe;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/mocha/observe.ts?");
+eval("\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar done_subscriber_1 = __webpack_require__(/*! ../done-subscriber */ \"./source/done-subscriber.ts\");\r\nfunction observe(observableTest) {\r\n    return function (done) {\r\n        var subscriber = new done_subscriber_1.DoneSubscriber(done, done);\r\n        observableTest().subscribe(subscriber);\r\n    };\r\n}\r\nexports.observe = observe;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/mocha/observe.ts?");
 
@@ -254,0 +266,0 @@ /***/ }),

CHANGELOG.md

@@ -0,1 +1,15 @@
+<a name="5.0.4"></a>
+## [5.0.4](https://github.com/cartant/rxjs-marbles/compare/v5.0.3...v5.0.4) (2019-12-14)
+
+### Fixes
+
+* The `observe` helper now reports assertions that fail within `finalize` operators. ([66e4093](https://github.com/cartant/rxjs-marbles/commit/66e4093))
+
+<a name="5.0.3"></a>
+## [5.0.3](https://github.com/cartant/rxjs-marbles/compare/v5.0.2...v5.1.3) (2019-09-14)
+
+### Fixes
+
+* Fix the incorrect patching within `fakeSchedulers`. ([e1d9c83](https://github.com/cartant/rxjs-marbles/commit/e1d9c83))
+
 <a name="5.0.2"></a>
@@ -2,0 +16,0 @@ ## [5.0.2](https://github.com/cartant/rxjs-marbles/compare/v5.0.1...v5.0.2) (2019-04-23)

context-deprecated.d.ts

@@ -15,3 +15,3 @@ import { Observable, SchedulerLike } from "rxjs";
     constructor(configuration_: Configuration);
-    readonly scheduler: TestScheduler;
+    get scheduler(): TestScheduler;
     bind(...schedulers: SchedulerLike[]): void;
@@ -18,0 +18,0 @@ cold<T = any>(marbles: string, values?: {

context-run.d.ts

@@ -11,3 +11,4 @@ import { Observable, SchedulerLike } from "rxjs";
     constructor(scheduler: TestScheduler, helpers_: RunHelpers);
-    autoFlush: boolean;
+    get autoFlush(): boolean;
+    set autoFlush(value: boolean);
     bind(...schedulers: SchedulerLike[]): void;
@@ -14,0 +15,0 @@ cold<T = any>(marbles: string, values?: {

esm2015/jasmine/observe.js

@@ -0,3 +1,7 @@
+import { DoneSubscriber } from "../done-subscriber";
 export function observe(observableTest) {
-    return (done) => observableTest().subscribe(undefined, done.fail, done);
+    return (done) => {
+        const subscriber = new DoneSubscriber(done.fail, done);
+        observableTest().subscribe(subscriber);
+    };
 }

esm2015/jest/observe.js

@@ -0,3 +1,7 @@
+import { DoneSubscriber } from "../done-subscriber";
 export function observe(observableTest) {
-    return (done) => observableTest().subscribe(undefined, done.fail, done);
+    return (done) => {
+        const subscriber = new DoneSubscriber(done.fail, done);
+        observableTest().subscribe(subscriber);
+    };
 }

esm2015/mocha/observe.js

@@ -0,3 +1,7 @@
+import { DoneSubscriber } from "../done-subscriber";
 export function observe(observableTest) {
-    return (done) => observableTest().subscribe(undefined, done, done);
+    return (done) => {
+        const subscriber = new DoneSubscriber(done, done);
+        observableTest().subscribe(subscriber);
+    };
 }

esm5/jasmine/observe.js

@@ -0,5 +1,7 @@
+import { DoneSubscriber } from "../done-subscriber";
 export function observe(observableTest) {
     return function (done) {
-        return observableTest().subscribe(undefined, done.fail, done);
+        var subscriber = new DoneSubscriber(done.fail, done);
+        observableTest().subscribe(subscriber);
     };
 }

esm5/jest/observe.js

@@ -0,5 +1,7 @@
+import { DoneSubscriber } from "../done-subscriber";
 export function observe(observableTest) {
     return function (done) {
-        return observableTest().subscribe(undefined, done.fail, done);
+        var subscriber = new DoneSubscriber(done.fail, done);
+        observableTest().subscribe(subscriber);
     };
 }

esm5/mocha/observe.js

@@ -0,5 +1,7 @@
+import { DoneSubscriber } from "../done-subscriber";
 export function observe(observableTest) {
     return function (done) {
-        return observableTest().subscribe(undefined, done, done);
+        var subscriber = new DoneSubscriber(done, done);
+        observableTest().subscribe(subscriber);
     };
 }

jasmine/observe.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+var done_subscriber_1 = require("../done-subscriber");
 function observe(observableTest) {
     return function (done) {
-        return observableTest().subscribe(undefined, done.fail, done);
+        var subscriber = new done_subscriber_1.DoneSubscriber(done.fail, done);
+        observableTest().subscribe(subscriber);
     };
 }
 exports.observe = observe;

jest/observe.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+var done_subscriber_1 = require("../done-subscriber");
 function observe(observableTest) {
     return function (done) {
-        return observableTest().subscribe(undefined, done.fail, done);
+        var subscriber = new done_subscriber_1.DoneSubscriber(done.fail, done);
+        observableTest().subscribe(subscriber);
     };
 }
 exports.observe = observe;

mocha/observe.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+var done_subscriber_1 = require("../done-subscriber");
 function observe(observableTest) {
     return function (done) {
-        return observableTest().subscribe(undefined, done, done);
+        var subscriber = new done_subscriber_1.DoneSubscriber(done, done);
+        observableTest().subscribe(subscriber);
     };
 }
 exports.observe = observe;

package.json

@@ -56,4 +56,4 @@ {
   "unpkg": "./bundles/rxjs-marbles.umd.js",
-  "version": "5.0.3",
+  "version": "5.0.4",
   "ava": {}
 }

README.md

@@ -36,3 +36,3 @@ # rxjs-marbles
 
-If you're just getting started with marble testing, you might be interested in how I wasted some of my time by not carefully reading the manual: [RxJS Marble Testing: RTFM](https://medium.com/@cartant/rxjs-marble-testing-rtfm-a9a6cd3db758).
+If you're just getting started with marble testing, you might be interested in how I wasted some of my time by not carefully reading the manual: [RxJS Marble Testing: RTFM](https://ncjamieson.com/marble-testing-rtfm/).
 
@@ -256,2 +256,2 @@ ## Usage
 
-Also, I've written an article on the `fakeSchedulers` function: [RxJS: Testing with Fake Time](https://medium.com/@cartant/rxjs-testing-with-fake-time-94114271eed2).
+Also, I've written an article on the `fakeSchedulers` function: [RxJS: Testing with Fake Time](https://ncjamieson.com/testing-with-fake-time/).

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Long strings

Supply chain risk

Contains long string literals, which may be a sign of obfuscated or packed code.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Mixed license

License

(Experimental) Package contains multiple licenses.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

443033

increased by2.23%

Number of package files

111

increased by3.74%

Number of low license alerts

0

decreased by-100%

Lines of code

4875

increased by3.2%

Worsened metrics

Number of low supply chain risk alerts

55

increased by5.77%

Number of medium supply chain risk alerts

91

increased by3.41%

No dependency changes