New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More →
Socket
Sign inDemoInstall
Socket
Sign inDemoInstall

rxjs-marbles

Package Overview
Dependencies
Maintainers
1
Versions
53
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

rxjs-marbles - npm Package Compare versions

Comparing version 5.0.1 to 5.0.2

8

bundles/rxjs-marbles-ava.umd.js

@@ -166,3 +166,3 @@ (function webpackUniversalModuleDefinition(root, factory) {

"use strict";
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar fast_equals_1 = __webpack_require__(/*! fast-equals */ \"./node_modules/fast-equals/dist/fast-equals.js\");\r\nvar defaultConfiguration = {\r\n assert: defaultAssert,\r\n assertDeepEqual: defaultAssertDeepEqual,\r\n frameworkMatcher: false,\r\n run: true\r\n};\r\nfunction defaults() {\r\n return __assign({}, defaultConfiguration);\r\n}\r\nexports.defaults = defaults;\r\nfunction defaultAssert(value, message) {\r\n if (value) {\r\n return;\r\n }\r\n throw new Error(message);\r\n}\r\nfunction defaultAssertDeepEqual(a, b) {\r\n if (fast_equals_1.deepEqual(a, b)) {\r\n return;\r\n }\r\n throw new Error(\"Expected \" + toString(a) + \" to equal \" + toString(b) + \".\");\r\n}\r\nfunction toString(value) {\r\n if (value === null) {\r\n return \"null\";\r\n }\r\n else if (value === undefined) {\r\n return \"undefined\";\r\n }\r\n return value.toString();\r\n}\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/configuration.ts?");
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar fast_equals_1 = __webpack_require__(/*! fast-equals */ \"./node_modules/fast-equals/dist/fast-equals.js\");\r\nvar defaultConfiguration = {\r\n assert: defaultAssert,\r\n assertDeepEqual: defaultAssertDeepEqual,\r\n frameworkMatcher: false,\r\n run: true\r\n};\r\nfunction defaults() {\r\n return __assign({}, defaultConfiguration);\r\n}\r\nexports.defaults = defaults;\r\nfunction defaultAssert(value, message) {\r\n if (value) {\r\n return;\r\n }\r\n throw new Error(message);\r\n}\r\nfunction defaultAssertDeepEqual(a, b) {\r\n if (fast_equals_1.circularDeepEqual(a, b)) {\r\n return;\r\n }\r\n throw new Error(\"Expected \" + toString(a) + \" to equal \" + toString(b) + \".\");\r\n}\r\nfunction toString(value) {\r\n if (value === null) {\r\n return \"null\";\r\n }\r\n else if (value === undefined) {\r\n return \"undefined\";\r\n }\r\n return value.toString();\r\n}\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/configuration.ts?");

@@ -179,3 +179,3 @@ /***/ }),

"use strict";
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar rxjs_1 = __webpack_require__(/*! rxjs */ \"rxjs\");\r\nvar testing_1 = __webpack_require__(/*! rxjs/testing */ \"rxjs/testing\");\r\nvar args_1 = __webpack_require__(/*! ./args */ \"./source/args.ts\");\r\nvar assert_1 = __webpack_require__(/*! ./assert */ \"./source/assert.ts\");\r\nvar expect_1 = __webpack_require__(/*! ./expect */ \"./source/expect.ts\");\r\nvar matcher_1 = __webpack_require__(/*! ./matcher */ \"./source/matcher.ts\");\r\nvar DeprecatedContext = (function () {\r\n function DeprecatedContext(configuration_) {\r\n this.configuration_ = configuration_;\r\n this.autoFlush = true;\r\n this.bindings_ = [];\r\n this.frameTimeFactor_ = undefined;\r\n this.reframable_ = true;\r\n }\r\n Object.defineProperty(DeprecatedContext.prototype, \"scheduler\", {\r\n get: function () {\r\n var _this = this;\r\n if (!this.scheduler_) {\r\n this.scheduler_ = new testing_1.TestScheduler(function (a, b) {\r\n return matcher_1.observableMatcher(a, b, _this.configuration_.assert, _this.configuration_.assertDeepEqual, _this.configuration_.frameworkMatcher);\r\n });\r\n }\r\n return this.scheduler_;\r\n },\r\n enumerable: true,\r\n configurable: true\r\n });\r\n DeprecatedContext.prototype.bind = function () {\r\n var _this = this;\r\n var schedulers = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n schedulers[_i] = arguments[_i];\r\n }\r\n if (this.bindings_.length !== 0) {\r\n throw new Error(\"Schedulers already bound.\");\r\n }\r\n if (schedulers.length === 0) {\r\n schedulers = [\r\n rxjs_1.animationFrameScheduler,\r\n rxjs_1.asapScheduler,\r\n rxjs_1.asyncScheduler,\r\n rxjs_1.queueScheduler\r\n ];\r\n }\r\n this.bindings_ = schedulers.map(function (instance) {\r\n var now = instance.hasOwnProperty(\"now\") ? instance.now : undefined;\r\n instance.now = function () { return _this.scheduler.now(); };\r\n var schedule = instance.hasOwnProperty(\"schedule\")\r\n ? instance.schedule\r\n : undefined;\r\n instance.schedule = function (work, delay, state) {\r\n return _this.scheduler.schedule(work, delay, state);\r\n };\r\n return { instance: instance, now: now, schedule: schedule };\r\n });\r\n };\r\n DeprecatedContext.prototype.cold = function (marbles, values, error) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n var observable = scheduler.createColdObservable(marbles, values, error);\r\n observable[args_1.argsSymbol] = { error: error, marbles: marbles, values: values };\r\n return observable;\r\n };\r\n DeprecatedContext.prototype.configure = function (configuration) {\r\n if (this.scheduler_) {\r\n throw new Error(\"Scheduler already created; call configure before using other context methods and properties.\");\r\n }\r\n this.configuration_ = __assign({}, this.configuration_, configuration);\r\n };\r\n DeprecatedContext.prototype.equal = function (actual) {\r\n var args = [];\r\n for (var _i = 1; _i < arguments.length; _i++) {\r\n args[_i - 1] = arguments[_i];\r\n }\r\n var scheduler = this.scheduler;\r\n var a0 = args[0], a1 = args[1], a2 = args[2], a3 = args[3];\r\n if (a1 && typeof a1 === \"string\") {\r\n scheduler.expectObservable(actual, a0).toBe(a1, a2, a3);\r\n }\r\n else if (a1 && a1[args_1.argsSymbol]) {\r\n assert_1.assertArgs(a1);\r\n var _a = a1[args_1.argsSymbol], error = _a.error, marbles = _a.marbles, values = _a.values;\r\n scheduler.expectObservable(actual, a0).toBe(marbles, values, error);\r\n }\r\n else if (typeof a0 === \"string\") {\r\n scheduler.expectObservable(actual).toBe(a0, a1, a2);\r\n }\r\n else {\r\n assert_1.assertArgs(a0);\r\n var _b = a0[args_1.argsSymbol], error = _b.error, marbles = _b.marbles, values = _b.values;\r\n scheduler.expectObservable(actual).toBe(marbles, values, error);\r\n }\r\n };\r\n DeprecatedContext.prototype.expect = function (actual, subscription) {\r\n var scheduler = this.scheduler;\r\n return new expect_1.Expect(actual, scheduler, subscription);\r\n };\r\n DeprecatedContext.prototype.flush = function () {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n scheduler.flush();\r\n };\r\n DeprecatedContext.prototype.has = function (actual, expected) {\r\n assert_1.assertSubscriptions(actual);\r\n var scheduler = this.scheduler;\r\n scheduler.expectSubscriptions(actual.subscriptions).toBe(expected);\r\n };\r\n DeprecatedContext.prototype.hot = function (marbles, values, error) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n var observable = scheduler.createHotObservable(marbles, values, error);\r\n observable[args_1.argsSymbol] = { error: error, marbles: marbles, values: values };\r\n return observable;\r\n };\r\n DeprecatedContext.prototype.reframe = function (timePerFrame, maxTime) {\r\n if (!this.reframable_) {\r\n throw new Error(\"Cannot reframe; scheduler already used.\");\r\n }\r\n if (maxTime === undefined) {\r\n maxTime = timePerFrame * 75;\r\n }\r\n this.frameTimeFactor_ =\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor ||\r\n testing_1.TestScheduler.frameTimeFactor;\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor = timePerFrame;\r\n testing_1.TestScheduler.frameTimeFactor = timePerFrame;\r\n var scheduler = this.scheduler;\r\n scheduler.maxFrames = maxTime;\r\n };\r\n DeprecatedContext.prototype.teardown = function () {\r\n try {\r\n if (this.autoFlush) {\r\n this.scheduler.flush();\r\n }\r\n }\r\n finally {\r\n this.bindings_.forEach(function (_a) {\r\n var instance = _a.instance, now = _a.now, schedule = _a.schedule;\r\n if (now) {\r\n instance.now = now;\r\n }\r\n else {\r\n delete instance.now;\r\n }\r\n if (schedule) {\r\n instance.schedule = schedule;\r\n }\r\n else {\r\n delete instance.schedule;\r\n }\r\n });\r\n if (this.frameTimeFactor_) {\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor = this.frameTimeFactor_;\r\n testing_1.TestScheduler.frameTimeFactor = this.frameTimeFactor_;\r\n }\r\n }\r\n };\r\n DeprecatedContext.prototype.time = function (marbles) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n return scheduler.createTime(marbles);\r\n };\r\n return DeprecatedContext;\r\n}());\r\nexports.DeprecatedContext = DeprecatedContext;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/context-deprecated.ts?");
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar rxjs_1 = __webpack_require__(/*! rxjs */ \"rxjs\");\r\nvar testing_1 = __webpack_require__(/*! rxjs/testing */ \"rxjs/testing\");\r\nvar args_1 = __webpack_require__(/*! ./args */ \"./source/args.ts\");\r\nvar assert_1 = __webpack_require__(/*! ./assert */ \"./source/assert.ts\");\r\nvar expect_1 = __webpack_require__(/*! ./expect */ \"./source/expect.ts\");\r\nvar matcher_1 = __webpack_require__(/*! ./matcher */ \"./source/matcher.ts\");\r\nvar DeprecatedContext = (function () {\r\n function DeprecatedContext(configuration_) {\r\n this.configuration_ = configuration_;\r\n this.autoFlush = true;\r\n this.bindings_ = [];\r\n this.frameTimeFactor_ = undefined;\r\n this.reframable_ = true;\r\n }\r\n Object.defineProperty(DeprecatedContext.prototype, \"scheduler\", {\r\n get: function () {\r\n var _this = this;\r\n if (!this.scheduler_) {\r\n this.scheduler_ = new testing_1.TestScheduler(function (actual, expected) {\r\n return matcher_1.observableMatcher(actual, expected, _this.configuration_.assert, _this.configuration_.assertDeepEqual, _this.configuration_.frameworkMatcher);\r\n });\r\n }\r\n return this.scheduler_;\r\n },\r\n enumerable: true,\r\n configurable: true\r\n });\r\n DeprecatedContext.prototype.bind = function () {\r\n var _this = this;\r\n var schedulers = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n schedulers[_i] = arguments[_i];\r\n }\r\n if (this.bindings_.length !== 0) {\r\n throw new Error(\"Schedulers already bound.\");\r\n }\r\n if (schedulers.length === 0) {\r\n schedulers = [\r\n rxjs_1.animationFrameScheduler,\r\n rxjs_1.asapScheduler,\r\n rxjs_1.asyncScheduler,\r\n rxjs_1.queueScheduler\r\n ];\r\n }\r\n this.bindings_ = schedulers.map(function (instance) {\r\n var now = instance.hasOwnProperty(\"now\") ? instance.now : undefined;\r\n instance.now = function () { return _this.scheduler.now(); };\r\n var schedule = instance.hasOwnProperty(\"schedule\")\r\n ? instance.schedule\r\n : undefined;\r\n instance.schedule = function (work, delay, state) {\r\n return _this.scheduler.schedule(work, delay, state);\r\n };\r\n return { instance: instance, now: now, schedule: schedule };\r\n });\r\n };\r\n DeprecatedContext.prototype.cold = function (marbles, values, error) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n var observable = scheduler.createColdObservable(marbles, values, error);\r\n observable[args_1.argsSymbol] = { error: error, marbles: marbles, values: values };\r\n return observable;\r\n };\r\n DeprecatedContext.prototype.configure = function (configuration) {\r\n if (this.scheduler_) {\r\n throw new Error(\"Scheduler already created; call configure before using other context methods and properties.\");\r\n }\r\n this.configuration_ = __assign({}, this.configuration_, configuration);\r\n };\r\n DeprecatedContext.prototype.equal = function (actual) {\r\n var args = [];\r\n for (var _i = 1; _i < arguments.length; _i++) {\r\n args[_i - 1] = arguments[_i];\r\n }\r\n var scheduler = this.scheduler;\r\n var a0 = args[0], a1 = args[1], a2 = args[2], a3 = args[3];\r\n if (a1 && typeof a1 === \"string\") {\r\n scheduler.expectObservable(actual, a0).toBe(a1, a2, a3);\r\n }\r\n else if (a1 && a1[args_1.argsSymbol]) {\r\n assert_1.assertArgs(a1);\r\n var _a = a1[args_1.argsSymbol], error = _a.error, marbles = _a.marbles, values = _a.values;\r\n scheduler.expectObservable(actual, a0).toBe(marbles, values, error);\r\n }\r\n else if (typeof a0 === \"string\") {\r\n scheduler.expectObservable(actual).toBe(a0, a1, a2);\r\n }\r\n else {\r\n assert_1.assertArgs(a0);\r\n var _b = a0[args_1.argsSymbol], error = _b.error, marbles = _b.marbles, values = _b.values;\r\n scheduler.expectObservable(actual).toBe(marbles, values, error);\r\n }\r\n };\r\n DeprecatedContext.prototype.expect = function (actual, subscription) {\r\n var scheduler = this.scheduler;\r\n return new expect_1.Expect(actual, scheduler, subscription);\r\n };\r\n DeprecatedContext.prototype.flush = function () {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n scheduler.flush();\r\n };\r\n DeprecatedContext.prototype.has = function (actual, expected) {\r\n assert_1.assertSubscriptions(actual);\r\n var scheduler = this.scheduler;\r\n scheduler.expectSubscriptions(actual.subscriptions).toBe(expected);\r\n };\r\n DeprecatedContext.prototype.hot = function (marbles, values, error) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n var observable = scheduler.createHotObservable(marbles, values, error);\r\n observable[args_1.argsSymbol] = { error: error, marbles: marbles, values: values };\r\n return observable;\r\n };\r\n DeprecatedContext.prototype.reframe = function (timePerFrame, maxTime) {\r\n if (!this.reframable_) {\r\n throw new Error(\"Cannot reframe; scheduler already used.\");\r\n }\r\n if (maxTime === undefined) {\r\n maxTime = timePerFrame * 75;\r\n }\r\n this.frameTimeFactor_ =\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor ||\r\n testing_1.TestScheduler.frameTimeFactor;\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor = timePerFrame;\r\n testing_1.TestScheduler.frameTimeFactor = timePerFrame;\r\n var scheduler = this.scheduler;\r\n scheduler.maxFrames = maxTime;\r\n };\r\n DeprecatedContext.prototype.teardown = function () {\r\n try {\r\n if (this.autoFlush) {\r\n this.scheduler.flush();\r\n }\r\n }\r\n finally {\r\n this.bindings_.forEach(function (_a) {\r\n var instance = _a.instance, now = _a.now, schedule = _a.schedule;\r\n if (now) {\r\n instance.now = now;\r\n }\r\n else {\r\n delete instance.now;\r\n }\r\n if (schedule) {\r\n instance.schedule = schedule;\r\n }\r\n else {\r\n delete instance.schedule;\r\n }\r\n });\r\n if (this.frameTimeFactor_) {\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor = this.frameTimeFactor_;\r\n testing_1.TestScheduler.frameTimeFactor = this.frameTimeFactor_;\r\n }\r\n }\r\n };\r\n DeprecatedContext.prototype.time = function (marbles) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n return scheduler.createTime(marbles);\r\n };\r\n return DeprecatedContext;\r\n}());\r\nexports.DeprecatedContext = DeprecatedContext;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/context-deprecated.ts?");

@@ -228,3 +228,3 @@ /***/ }),

"use strict";
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar testing_1 = __webpack_require__(/*! rxjs/testing */ \"rxjs/testing\");\r\nvar configuration_1 = __webpack_require__(/*! ./configuration */ \"./source/configuration.ts\");\r\nvar context_deprecated_1 = __webpack_require__(/*! ./context-deprecated */ \"./source/context-deprecated.ts\");\r\nvar context_run_1 = __webpack_require__(/*! ./context-run */ \"./source/context-run.ts\");\r\nvar matcher_1 = __webpack_require__(/*! ./matcher */ \"./source/matcher.ts\");\r\nfunction configure(configurationOrFactory) {\r\n function deriveConfiguration() {\r\n var args = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n args[_i] = arguments[_i];\r\n }\r\n var explicit = typeof configurationOrFactory === \"function\"\r\n ? configurationOrFactory.apply(void 0, args) : configurationOrFactory;\r\n return __assign({}, configuration_1.defaults(), explicit);\r\n }\r\n function _marbles(func) {\r\n var wrapper = function () {\r\n var _this = this;\r\n var rest = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n rest[_i] = arguments[_i];\r\n }\r\n var configuration = deriveConfiguration.apply(void 0, rest);\r\n if (configuration.run) {\r\n var scheduler_1 = new testing_1.TestScheduler(function (a, b) {\r\n return matcher_1.observableMatcher(a, b, configuration.assert, configuration.assertDeepEqual, configuration.frameworkMatcher);\r\n });\r\n return scheduler_1.run(function (helpers) {\r\n return func.call.apply(func, [_this, new context_run_1.RunContext(scheduler_1, helpers)].concat(rest));\r\n });\r\n }\r\n var context = new context_deprecated_1.DeprecatedContext(configuration);\r\n try {\r\n return func.call.apply(func, [this, context].concat(rest));\r\n }\r\n finally {\r\n context.teardown();\r\n }\r\n };\r\n if (func.length > 1) {\r\n return function (first) {\r\n var rest = [];\r\n for (var _i = 1; _i < arguments.length; _i++) {\r\n rest[_i - 1] = arguments[_i];\r\n }\r\n return wrapper.apply(void 0, [first].concat(rest));\r\n };\r\n }\r\n return wrapper;\r\n }\r\n return { marbles: _marbles };\r\n}\r\nexports.configure = configure;\r\nexports.marbles = configure(configuration_1.defaults()).marbles;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/marbles.ts?");
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar testing_1 = __webpack_require__(/*! rxjs/testing */ \"rxjs/testing\");\r\nvar configuration_1 = __webpack_require__(/*! ./configuration */ \"./source/configuration.ts\");\r\nvar context_deprecated_1 = __webpack_require__(/*! ./context-deprecated */ \"./source/context-deprecated.ts\");\r\nvar context_run_1 = __webpack_require__(/*! ./context-run */ \"./source/context-run.ts\");\r\nvar matcher_1 = __webpack_require__(/*! ./matcher */ \"./source/matcher.ts\");\r\nfunction configure(configurationOrFactory) {\r\n function deriveConfiguration() {\r\n var args = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n args[_i] = arguments[_i];\r\n }\r\n var explicit = typeof configurationOrFactory === \"function\"\r\n ? configurationOrFactory.apply(void 0, args) : configurationOrFactory;\r\n return __assign({}, configuration_1.defaults(), explicit);\r\n }\r\n function _marbles(func) {\r\n var wrapper = function () {\r\n var _this = this;\r\n var rest = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n rest[_i] = arguments[_i];\r\n }\r\n var configuration = deriveConfiguration.apply(void 0, rest);\r\n if (configuration.run) {\r\n var scheduler_1 = new testing_1.TestScheduler(function (actual, expected) {\r\n return matcher_1.observableMatcher(actual, expected, configuration.assert, configuration.assertDeepEqual, configuration.frameworkMatcher);\r\n });\r\n return scheduler_1.run(function (helpers) {\r\n return func.call.apply(func, [_this, new context_run_1.RunContext(scheduler_1, helpers)].concat(rest));\r\n });\r\n }\r\n var context = new context_deprecated_1.DeprecatedContext(configuration);\r\n try {\r\n return func.call.apply(func, [this, context].concat(rest));\r\n }\r\n finally {\r\n context.teardown();\r\n }\r\n };\r\n if (func.length > 1) {\r\n return function (first) {\r\n var rest = [];\r\n for (var _i = 1; _i < arguments.length; _i++) {\r\n rest[_i - 1] = arguments[_i];\r\n }\r\n return wrapper.apply(void 0, [first].concat(rest));\r\n };\r\n }\r\n return wrapper;\r\n }\r\n return { marbles: _marbles };\r\n}\r\nexports.configure = configure;\r\nexports.marbles = configure(configuration_1.defaults()).marbles;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/marbles.ts?");

@@ -241,3 +241,3 @@ /***/ }),

"use strict";
eval("\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar fast_equals_1 = __webpack_require__(/*! fast-equals */ \"./node_modules/fast-equals/dist/fast-equals.js\");\r\nfunction stringify(x) {\r\n if (x === undefined) {\r\n return \"undefined\";\r\n }\r\n return JSON.stringify(x, function (key, value) {\r\n if (Array.isArray(value)) {\r\n return (\"[\" +\r\n value.map(function (i) {\r\n return \"\\n\\t\" + stringify(i);\r\n }) +\r\n \"\\n]\");\r\n }\r\n return value;\r\n })\r\n .replace(/\\\\\"/g, '\"')\r\n .replace(/\\\\t/g, \"\\t\")\r\n .replace(/\\\\n/g, \"\\n\");\r\n}\r\nfunction deleteErrorNotificationStack(marble) {\r\n var notification = marble.notification;\r\n if (notification) {\r\n var kind = notification.kind, error = notification.error;\r\n if (kind === \"E\" && error instanceof Error) {\r\n notification.error = { name: error.name, message: error.message };\r\n }\r\n }\r\n return marble;\r\n}\r\nfunction observableMatcher(actual, expected, assert, assertDeepEqual, frameworkMatcher) {\r\n if (Array.isArray(actual) && Array.isArray(expected)) {\r\n actual = actual.map(deleteErrorNotificationStack);\r\n expected = expected.map(deleteErrorNotificationStack);\r\n if (frameworkMatcher) {\r\n assertDeepEqual(actual, expected);\r\n }\r\n else {\r\n var passed = fast_equals_1.deepEqual(actual, expected);\r\n if (passed) {\r\n assert(true, \"\");\r\n return;\r\n }\r\n var message_1 = \"\\nExpected \\n\";\r\n actual.forEach(function (x) { return (message_1 += \"\\t\" + stringify(x) + \"\\n\"); });\r\n message_1 += \"\\t\\nto deep equal \\n\";\r\n expected.forEach(function (x) { return (message_1 += \"\\t\" + stringify(x) + \"\\n\"); });\r\n assert(passed, message_1);\r\n }\r\n }\r\n else {\r\n assertDeepEqual(actual, expected);\r\n }\r\n}\r\nexports.observableMatcher = observableMatcher;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/matcher.ts?");
eval("\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar fast_equals_1 = __webpack_require__(/*! fast-equals */ \"./node_modules/fast-equals/dist/fast-equals.js\");\r\nfunction stringify(x) {\r\n if (x === undefined) {\r\n return \"undefined\";\r\n }\r\n return JSON.stringify(x, function (key, value) {\r\n if (Array.isArray(value)) {\r\n return (\"[\" +\r\n value.map(function (i) {\r\n return \"\\n\\t\" + stringify(i);\r\n }) +\r\n \"\\n]\");\r\n }\r\n return value;\r\n })\r\n .replace(/\\\\\"/g, '\"')\r\n .replace(/\\\\t/g, \"\\t\")\r\n .replace(/\\\\n/g, \"\\n\");\r\n}\r\nfunction deleteErrorNotificationStack(marble) {\r\n var notification = marble.notification;\r\n if (notification) {\r\n var kind = notification.kind, error = notification.error;\r\n if (kind === \"E\" && error instanceof Error) {\r\n notification.error = { name: error.name, message: error.message };\r\n }\r\n }\r\n return marble;\r\n}\r\nfunction observableMatcher(actual, expected, assert, assertDeepEqual, frameworkMatcher) {\r\n if (Array.isArray(actual) && Array.isArray(expected)) {\r\n actual = actual.map(deleteErrorNotificationStack);\r\n expected = expected.map(deleteErrorNotificationStack);\r\n if (frameworkMatcher) {\r\n assertDeepEqual(actual, expected);\r\n }\r\n else {\r\n var passed = fast_equals_1.circularDeepEqual(actual, expected);\r\n if (passed) {\r\n assert(true, \"\");\r\n return;\r\n }\r\n var message_1 = \"\\nExpected \\n\";\r\n actual.forEach(function (x) { return (message_1 += \"\\t\" + stringify(x) + \"\\n\"); });\r\n message_1 += \"\\t\\nto deep equal \\n\";\r\n expected.forEach(function (x) { return (message_1 += \"\\t\" + stringify(x) + \"\\n\"); });\r\n assert(passed, message_1);\r\n }\r\n }\r\n else {\r\n assertDeepEqual(actual, expected);\r\n }\r\n}\r\nexports.observableMatcher = observableMatcher;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/matcher.ts?");

@@ -244,0 +244,0 @@ /***/ }),

8

bundles/rxjs-marbles-jasmine.umd.js

@@ -154,3 +154,3 @@ (function webpackUniversalModuleDefinition(root, factory) {

"use strict";
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar fast_equals_1 = __webpack_require__(/*! fast-equals */ \"./node_modules/fast-equals/dist/fast-equals.js\");\r\nvar defaultConfiguration = {\r\n assert: defaultAssert,\r\n assertDeepEqual: defaultAssertDeepEqual,\r\n frameworkMatcher: false,\r\n run: true\r\n};\r\nfunction defaults() {\r\n return __assign({}, defaultConfiguration);\r\n}\r\nexports.defaults = defaults;\r\nfunction defaultAssert(value, message) {\r\n if (value) {\r\n return;\r\n }\r\n throw new Error(message);\r\n}\r\nfunction defaultAssertDeepEqual(a, b) {\r\n if (fast_equals_1.deepEqual(a, b)) {\r\n return;\r\n }\r\n throw new Error(\"Expected \" + toString(a) + \" to equal \" + toString(b) + \".\");\r\n}\r\nfunction toString(value) {\r\n if (value === null) {\r\n return \"null\";\r\n }\r\n else if (value === undefined) {\r\n return \"undefined\";\r\n }\r\n return value.toString();\r\n}\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/configuration.ts?");
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar fast_equals_1 = __webpack_require__(/*! fast-equals */ \"./node_modules/fast-equals/dist/fast-equals.js\");\r\nvar defaultConfiguration = {\r\n assert: defaultAssert,\r\n assertDeepEqual: defaultAssertDeepEqual,\r\n frameworkMatcher: false,\r\n run: true\r\n};\r\nfunction defaults() {\r\n return __assign({}, defaultConfiguration);\r\n}\r\nexports.defaults = defaults;\r\nfunction defaultAssert(value, message) {\r\n if (value) {\r\n return;\r\n }\r\n throw new Error(message);\r\n}\r\nfunction defaultAssertDeepEqual(a, b) {\r\n if (fast_equals_1.circularDeepEqual(a, b)) {\r\n return;\r\n }\r\n throw new Error(\"Expected \" + toString(a) + \" to equal \" + toString(b) + \".\");\r\n}\r\nfunction toString(value) {\r\n if (value === null) {\r\n return \"null\";\r\n }\r\n else if (value === undefined) {\r\n return \"undefined\";\r\n }\r\n return value.toString();\r\n}\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/configuration.ts?");

@@ -167,3 +167,3 @@ /***/ }),

"use strict";
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar rxjs_1 = __webpack_require__(/*! rxjs */ \"rxjs\");\r\nvar testing_1 = __webpack_require__(/*! rxjs/testing */ \"rxjs/testing\");\r\nvar args_1 = __webpack_require__(/*! ./args */ \"./source/args.ts\");\r\nvar assert_1 = __webpack_require__(/*! ./assert */ \"./source/assert.ts\");\r\nvar expect_1 = __webpack_require__(/*! ./expect */ \"./source/expect.ts\");\r\nvar matcher_1 = __webpack_require__(/*! ./matcher */ \"./source/matcher.ts\");\r\nvar DeprecatedContext = (function () {\r\n function DeprecatedContext(configuration_) {\r\n this.configuration_ = configuration_;\r\n this.autoFlush = true;\r\n this.bindings_ = [];\r\n this.frameTimeFactor_ = undefined;\r\n this.reframable_ = true;\r\n }\r\n Object.defineProperty(DeprecatedContext.prototype, \"scheduler\", {\r\n get: function () {\r\n var _this = this;\r\n if (!this.scheduler_) {\r\n this.scheduler_ = new testing_1.TestScheduler(function (a, b) {\r\n return matcher_1.observableMatcher(a, b, _this.configuration_.assert, _this.configuration_.assertDeepEqual, _this.configuration_.frameworkMatcher);\r\n });\r\n }\r\n return this.scheduler_;\r\n },\r\n enumerable: true,\r\n configurable: true\r\n });\r\n DeprecatedContext.prototype.bind = function () {\r\n var _this = this;\r\n var schedulers = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n schedulers[_i] = arguments[_i];\r\n }\r\n if (this.bindings_.length !== 0) {\r\n throw new Error(\"Schedulers already bound.\");\r\n }\r\n if (schedulers.length === 0) {\r\n schedulers = [\r\n rxjs_1.animationFrameScheduler,\r\n rxjs_1.asapScheduler,\r\n rxjs_1.asyncScheduler,\r\n rxjs_1.queueScheduler\r\n ];\r\n }\r\n this.bindings_ = schedulers.map(function (instance) {\r\n var now = instance.hasOwnProperty(\"now\") ? instance.now : undefined;\r\n instance.now = function () { return _this.scheduler.now(); };\r\n var schedule = instance.hasOwnProperty(\"schedule\")\r\n ? instance.schedule\r\n : undefined;\r\n instance.schedule = function (work, delay, state) {\r\n return _this.scheduler.schedule(work, delay, state);\r\n };\r\n return { instance: instance, now: now, schedule: schedule };\r\n });\r\n };\r\n DeprecatedContext.prototype.cold = function (marbles, values, error) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n var observable = scheduler.createColdObservable(marbles, values, error);\r\n observable[args_1.argsSymbol] = { error: error, marbles: marbles, values: values };\r\n return observable;\r\n };\r\n DeprecatedContext.prototype.configure = function (configuration) {\r\n if (this.scheduler_) {\r\n throw new Error(\"Scheduler already created; call configure before using other context methods and properties.\");\r\n }\r\n this.configuration_ = __assign({}, this.configuration_, configuration);\r\n };\r\n DeprecatedContext.prototype.equal = function (actual) {\r\n var args = [];\r\n for (var _i = 1; _i < arguments.length; _i++) {\r\n args[_i - 1] = arguments[_i];\r\n }\r\n var scheduler = this.scheduler;\r\n var a0 = args[0], a1 = args[1], a2 = args[2], a3 = args[3];\r\n if (a1 && typeof a1 === \"string\") {\r\n scheduler.expectObservable(actual, a0).toBe(a1, a2, a3);\r\n }\r\n else if (a1 && a1[args_1.argsSymbol]) {\r\n assert_1.assertArgs(a1);\r\n var _a = a1[args_1.argsSymbol], error = _a.error, marbles = _a.marbles, values = _a.values;\r\n scheduler.expectObservable(actual, a0).toBe(marbles, values, error);\r\n }\r\n else if (typeof a0 === \"string\") {\r\n scheduler.expectObservable(actual).toBe(a0, a1, a2);\r\n }\r\n else {\r\n assert_1.assertArgs(a0);\r\n var _b = a0[args_1.argsSymbol], error = _b.error, marbles = _b.marbles, values = _b.values;\r\n scheduler.expectObservable(actual).toBe(marbles, values, error);\r\n }\r\n };\r\n DeprecatedContext.prototype.expect = function (actual, subscription) {\r\n var scheduler = this.scheduler;\r\n return new expect_1.Expect(actual, scheduler, subscription);\r\n };\r\n DeprecatedContext.prototype.flush = function () {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n scheduler.flush();\r\n };\r\n DeprecatedContext.prototype.has = function (actual, expected) {\r\n assert_1.assertSubscriptions(actual);\r\n var scheduler = this.scheduler;\r\n scheduler.expectSubscriptions(actual.subscriptions).toBe(expected);\r\n };\r\n DeprecatedContext.prototype.hot = function (marbles, values, error) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n var observable = scheduler.createHotObservable(marbles, values, error);\r\n observable[args_1.argsSymbol] = { error: error, marbles: marbles, values: values };\r\n return observable;\r\n };\r\n DeprecatedContext.prototype.reframe = function (timePerFrame, maxTime) {\r\n if (!this.reframable_) {\r\n throw new Error(\"Cannot reframe; scheduler already used.\");\r\n }\r\n if (maxTime === undefined) {\r\n maxTime = timePerFrame * 75;\r\n }\r\n this.frameTimeFactor_ =\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor ||\r\n testing_1.TestScheduler.frameTimeFactor;\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor = timePerFrame;\r\n testing_1.TestScheduler.frameTimeFactor = timePerFrame;\r\n var scheduler = this.scheduler;\r\n scheduler.maxFrames = maxTime;\r\n };\r\n DeprecatedContext.prototype.teardown = function () {\r\n try {\r\n if (this.autoFlush) {\r\n this.scheduler.flush();\r\n }\r\n }\r\n finally {\r\n this.bindings_.forEach(function (_a) {\r\n var instance = _a.instance, now = _a.now, schedule = _a.schedule;\r\n if (now) {\r\n instance.now = now;\r\n }\r\n else {\r\n delete instance.now;\r\n }\r\n if (schedule) {\r\n instance.schedule = schedule;\r\n }\r\n else {\r\n delete instance.schedule;\r\n }\r\n });\r\n if (this.frameTimeFactor_) {\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor = this.frameTimeFactor_;\r\n testing_1.TestScheduler.frameTimeFactor = this.frameTimeFactor_;\r\n }\r\n }\r\n };\r\n DeprecatedContext.prototype.time = function (marbles) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n return scheduler.createTime(marbles);\r\n };\r\n return DeprecatedContext;\r\n}());\r\nexports.DeprecatedContext = DeprecatedContext;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/context-deprecated.ts?");
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar rxjs_1 = __webpack_require__(/*! rxjs */ \"rxjs\");\r\nvar testing_1 = __webpack_require__(/*! rxjs/testing */ \"rxjs/testing\");\r\nvar args_1 = __webpack_require__(/*! ./args */ \"./source/args.ts\");\r\nvar assert_1 = __webpack_require__(/*! ./assert */ \"./source/assert.ts\");\r\nvar expect_1 = __webpack_require__(/*! ./expect */ \"./source/expect.ts\");\r\nvar matcher_1 = __webpack_require__(/*! ./matcher */ \"./source/matcher.ts\");\r\nvar DeprecatedContext = (function () {\r\n function DeprecatedContext(configuration_) {\r\n this.configuration_ = configuration_;\r\n this.autoFlush = true;\r\n this.bindings_ = [];\r\n this.frameTimeFactor_ = undefined;\r\n this.reframable_ = true;\r\n }\r\n Object.defineProperty(DeprecatedContext.prototype, \"scheduler\", {\r\n get: function () {\r\n var _this = this;\r\n if (!this.scheduler_) {\r\n this.scheduler_ = new testing_1.TestScheduler(function (actual, expected) {\r\n return matcher_1.observableMatcher(actual, expected, _this.configuration_.assert, _this.configuration_.assertDeepEqual, _this.configuration_.frameworkMatcher);\r\n });\r\n }\r\n return this.scheduler_;\r\n },\r\n enumerable: true,\r\n configurable: true\r\n });\r\n DeprecatedContext.prototype.bind = function () {\r\n var _this = this;\r\n var schedulers = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n schedulers[_i] = arguments[_i];\r\n }\r\n if (this.bindings_.length !== 0) {\r\n throw new Error(\"Schedulers already bound.\");\r\n }\r\n if (schedulers.length === 0) {\r\n schedulers = [\r\n rxjs_1.animationFrameScheduler,\r\n rxjs_1.asapScheduler,\r\n rxjs_1.asyncScheduler,\r\n rxjs_1.queueScheduler\r\n ];\r\n }\r\n this.bindings_ = schedulers.map(function (instance) {\r\n var now = instance.hasOwnProperty(\"now\") ? instance.now : undefined;\r\n instance.now = function () { return _this.scheduler.now(); };\r\n var schedule = instance.hasOwnProperty(\"schedule\")\r\n ? instance.schedule\r\n : undefined;\r\n instance.schedule = function (work, delay, state) {\r\n return _this.scheduler.schedule(work, delay, state);\r\n };\r\n return { instance: instance, now: now, schedule: schedule };\r\n });\r\n };\r\n DeprecatedContext.prototype.cold = function (marbles, values, error) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n var observable = scheduler.createColdObservable(marbles, values, error);\r\n observable[args_1.argsSymbol] = { error: error, marbles: marbles, values: values };\r\n return observable;\r\n };\r\n DeprecatedContext.prototype.configure = function (configuration) {\r\n if (this.scheduler_) {\r\n throw new Error(\"Scheduler already created; call configure before using other context methods and properties.\");\r\n }\r\n this.configuration_ = __assign({}, this.configuration_, configuration);\r\n };\r\n DeprecatedContext.prototype.equal = function (actual) {\r\n var args = [];\r\n for (var _i = 1; _i < arguments.length; _i++) {\r\n args[_i - 1] = arguments[_i];\r\n }\r\n var scheduler = this.scheduler;\r\n var a0 = args[0], a1 = args[1], a2 = args[2], a3 = args[3];\r\n if (a1 && typeof a1 === \"string\") {\r\n scheduler.expectObservable(actual, a0).toBe(a1, a2, a3);\r\n }\r\n else if (a1 && a1[args_1.argsSymbol]) {\r\n assert_1.assertArgs(a1);\r\n var _a = a1[args_1.argsSymbol], error = _a.error, marbles = _a.marbles, values = _a.values;\r\n scheduler.expectObservable(actual, a0).toBe(marbles, values, error);\r\n }\r\n else if (typeof a0 === \"string\") {\r\n scheduler.expectObservable(actual).toBe(a0, a1, a2);\r\n }\r\n else {\r\n assert_1.assertArgs(a0);\r\n var _b = a0[args_1.argsSymbol], error = _b.error, marbles = _b.marbles, values = _b.values;\r\n scheduler.expectObservable(actual).toBe(marbles, values, error);\r\n }\r\n };\r\n DeprecatedContext.prototype.expect = function (actual, subscription) {\r\n var scheduler = this.scheduler;\r\n return new expect_1.Expect(actual, scheduler, subscription);\r\n };\r\n DeprecatedContext.prototype.flush = function () {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n scheduler.flush();\r\n };\r\n DeprecatedContext.prototype.has = function (actual, expected) {\r\n assert_1.assertSubscriptions(actual);\r\n var scheduler = this.scheduler;\r\n scheduler.expectSubscriptions(actual.subscriptions).toBe(expected);\r\n };\r\n DeprecatedContext.prototype.hot = function (marbles, values, error) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n var observable = scheduler.createHotObservable(marbles, values, error);\r\n observable[args_1.argsSymbol] = { error: error, marbles: marbles, values: values };\r\n return observable;\r\n };\r\n DeprecatedContext.prototype.reframe = function (timePerFrame, maxTime) {\r\n if (!this.reframable_) {\r\n throw new Error(\"Cannot reframe; scheduler already used.\");\r\n }\r\n if (maxTime === undefined) {\r\n maxTime = timePerFrame * 75;\r\n }\r\n this.frameTimeFactor_ =\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor ||\r\n testing_1.TestScheduler.frameTimeFactor;\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor = timePerFrame;\r\n testing_1.TestScheduler.frameTimeFactor = timePerFrame;\r\n var scheduler = this.scheduler;\r\n scheduler.maxFrames = maxTime;\r\n };\r\n DeprecatedContext.prototype.teardown = function () {\r\n try {\r\n if (this.autoFlush) {\r\n this.scheduler.flush();\r\n }\r\n }\r\n finally {\r\n this.bindings_.forEach(function (_a) {\r\n var instance = _a.instance, now = _a.now, schedule = _a.schedule;\r\n if (now) {\r\n instance.now = now;\r\n }\r\n else {\r\n delete instance.now;\r\n }\r\n if (schedule) {\r\n instance.schedule = schedule;\r\n }\r\n else {\r\n delete instance.schedule;\r\n }\r\n });\r\n if (this.frameTimeFactor_) {\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor = this.frameTimeFactor_;\r\n testing_1.TestScheduler.frameTimeFactor = this.frameTimeFactor_;\r\n }\r\n }\r\n };\r\n DeprecatedContext.prototype.time = function (marbles) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n return scheduler.createTime(marbles);\r\n };\r\n return DeprecatedContext;\r\n}());\r\nexports.DeprecatedContext = DeprecatedContext;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/context-deprecated.ts?");

@@ -240,3 +240,3 @@ /***/ }),

"use strict";
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar testing_1 = __webpack_require__(/*! rxjs/testing */ \"rxjs/testing\");\r\nvar configuration_1 = __webpack_require__(/*! ./configuration */ \"./source/configuration.ts\");\r\nvar context_deprecated_1 = __webpack_require__(/*! ./context-deprecated */ \"./source/context-deprecated.ts\");\r\nvar context_run_1 = __webpack_require__(/*! ./context-run */ \"./source/context-run.ts\");\r\nvar matcher_1 = __webpack_require__(/*! ./matcher */ \"./source/matcher.ts\");\r\nfunction configure(configurationOrFactory) {\r\n function deriveConfiguration() {\r\n var args = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n args[_i] = arguments[_i];\r\n }\r\n var explicit = typeof configurationOrFactory === \"function\"\r\n ? configurationOrFactory.apply(void 0, args) : configurationOrFactory;\r\n return __assign({}, configuration_1.defaults(), explicit);\r\n }\r\n function _marbles(func) {\r\n var wrapper = function () {\r\n var _this = this;\r\n var rest = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n rest[_i] = arguments[_i];\r\n }\r\n var configuration = deriveConfiguration.apply(void 0, rest);\r\n if (configuration.run) {\r\n var scheduler_1 = new testing_1.TestScheduler(function (a, b) {\r\n return matcher_1.observableMatcher(a, b, configuration.assert, configuration.assertDeepEqual, configuration.frameworkMatcher);\r\n });\r\n return scheduler_1.run(function (helpers) {\r\n return func.call.apply(func, [_this, new context_run_1.RunContext(scheduler_1, helpers)].concat(rest));\r\n });\r\n }\r\n var context = new context_deprecated_1.DeprecatedContext(configuration);\r\n try {\r\n return func.call.apply(func, [this, context].concat(rest));\r\n }\r\n finally {\r\n context.teardown();\r\n }\r\n };\r\n if (func.length > 1) {\r\n return function (first) {\r\n var rest = [];\r\n for (var _i = 1; _i < arguments.length; _i++) {\r\n rest[_i - 1] = arguments[_i];\r\n }\r\n return wrapper.apply(void 0, [first].concat(rest));\r\n };\r\n }\r\n return wrapper;\r\n }\r\n return { marbles: _marbles };\r\n}\r\nexports.configure = configure;\r\nexports.marbles = configure(configuration_1.defaults()).marbles;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/marbles.ts?");
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar testing_1 = __webpack_require__(/*! rxjs/testing */ \"rxjs/testing\");\r\nvar configuration_1 = __webpack_require__(/*! ./configuration */ \"./source/configuration.ts\");\r\nvar context_deprecated_1 = __webpack_require__(/*! ./context-deprecated */ \"./source/context-deprecated.ts\");\r\nvar context_run_1 = __webpack_require__(/*! ./context-run */ \"./source/context-run.ts\");\r\nvar matcher_1 = __webpack_require__(/*! ./matcher */ \"./source/matcher.ts\");\r\nfunction configure(configurationOrFactory) {\r\n function deriveConfiguration() {\r\n var args = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n args[_i] = arguments[_i];\r\n }\r\n var explicit = typeof configurationOrFactory === \"function\"\r\n ? configurationOrFactory.apply(void 0, args) : configurationOrFactory;\r\n return __assign({}, configuration_1.defaults(), explicit);\r\n }\r\n function _marbles(func) {\r\n var wrapper = function () {\r\n var _this = this;\r\n var rest = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n rest[_i] = arguments[_i];\r\n }\r\n var configuration = deriveConfiguration.apply(void 0, rest);\r\n if (configuration.run) {\r\n var scheduler_1 = new testing_1.TestScheduler(function (actual, expected) {\r\n return matcher_1.observableMatcher(actual, expected, configuration.assert, configuration.assertDeepEqual, configuration.frameworkMatcher);\r\n });\r\n return scheduler_1.run(function (helpers) {\r\n return func.call.apply(func, [_this, new context_run_1.RunContext(scheduler_1, helpers)].concat(rest));\r\n });\r\n }\r\n var context = new context_deprecated_1.DeprecatedContext(configuration);\r\n try {\r\n return func.call.apply(func, [this, context].concat(rest));\r\n }\r\n finally {\r\n context.teardown();\r\n }\r\n };\r\n if (func.length > 1) {\r\n return function (first) {\r\n var rest = [];\r\n for (var _i = 1; _i < arguments.length; _i++) {\r\n rest[_i - 1] = arguments[_i];\r\n }\r\n return wrapper.apply(void 0, [first].concat(rest));\r\n };\r\n }\r\n return wrapper;\r\n }\r\n return { marbles: _marbles };\r\n}\r\nexports.configure = configure;\r\nexports.marbles = configure(configuration_1.defaults()).marbles;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/marbles.ts?");

@@ -253,3 +253,3 @@ /***/ }),

"use strict";
eval("\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar fast_equals_1 = __webpack_require__(/*! fast-equals */ \"./node_modules/fast-equals/dist/fast-equals.js\");\r\nfunction stringify(x) {\r\n if (x === undefined) {\r\n return \"undefined\";\r\n }\r\n return JSON.stringify(x, function (key, value) {\r\n if (Array.isArray(value)) {\r\n return (\"[\" +\r\n value.map(function (i) {\r\n return \"\\n\\t\" + stringify(i);\r\n }) +\r\n \"\\n]\");\r\n }\r\n return value;\r\n })\r\n .replace(/\\\\\"/g, '\"')\r\n .replace(/\\\\t/g, \"\\t\")\r\n .replace(/\\\\n/g, \"\\n\");\r\n}\r\nfunction deleteErrorNotificationStack(marble) {\r\n var notification = marble.notification;\r\n if (notification) {\r\n var kind = notification.kind, error = notification.error;\r\n if (kind === \"E\" && error instanceof Error) {\r\n notification.error = { name: error.name, message: error.message };\r\n }\r\n }\r\n return marble;\r\n}\r\nfunction observableMatcher(actual, expected, assert, assertDeepEqual, frameworkMatcher) {\r\n if (Array.isArray(actual) && Array.isArray(expected)) {\r\n actual = actual.map(deleteErrorNotificationStack);\r\n expected = expected.map(deleteErrorNotificationStack);\r\n if (frameworkMatcher) {\r\n assertDeepEqual(actual, expected);\r\n }\r\n else {\r\n var passed = fast_equals_1.deepEqual(actual, expected);\r\n if (passed) {\r\n assert(true, \"\");\r\n return;\r\n }\r\n var message_1 = \"\\nExpected \\n\";\r\n actual.forEach(function (x) { return (message_1 += \"\\t\" + stringify(x) + \"\\n\"); });\r\n message_1 += \"\\t\\nto deep equal \\n\";\r\n expected.forEach(function (x) { return (message_1 += \"\\t\" + stringify(x) + \"\\n\"); });\r\n assert(passed, message_1);\r\n }\r\n }\r\n else {\r\n assertDeepEqual(actual, expected);\r\n }\r\n}\r\nexports.observableMatcher = observableMatcher;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/matcher.ts?");
eval("\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar fast_equals_1 = __webpack_require__(/*! fast-equals */ \"./node_modules/fast-equals/dist/fast-equals.js\");\r\nfunction stringify(x) {\r\n if (x === undefined) {\r\n return \"undefined\";\r\n }\r\n return JSON.stringify(x, function (key, value) {\r\n if (Array.isArray(value)) {\r\n return (\"[\" +\r\n value.map(function (i) {\r\n return \"\\n\\t\" + stringify(i);\r\n }) +\r\n \"\\n]\");\r\n }\r\n return value;\r\n })\r\n .replace(/\\\\\"/g, '\"')\r\n .replace(/\\\\t/g, \"\\t\")\r\n .replace(/\\\\n/g, \"\\n\");\r\n}\r\nfunction deleteErrorNotificationStack(marble) {\r\n var notification = marble.notification;\r\n if (notification) {\r\n var kind = notification.kind, error = notification.error;\r\n if (kind === \"E\" && error instanceof Error) {\r\n notification.error = { name: error.name, message: error.message };\r\n }\r\n }\r\n return marble;\r\n}\r\nfunction observableMatcher(actual, expected, assert, assertDeepEqual, frameworkMatcher) {\r\n if (Array.isArray(actual) && Array.isArray(expected)) {\r\n actual = actual.map(deleteErrorNotificationStack);\r\n expected = expected.map(deleteErrorNotificationStack);\r\n if (frameworkMatcher) {\r\n assertDeepEqual(actual, expected);\r\n }\r\n else {\r\n var passed = fast_equals_1.circularDeepEqual(actual, expected);\r\n if (passed) {\r\n assert(true, \"\");\r\n return;\r\n }\r\n var message_1 = \"\\nExpected \\n\";\r\n actual.forEach(function (x) { return (message_1 += \"\\t\" + stringify(x) + \"\\n\"); });\r\n message_1 += \"\\t\\nto deep equal \\n\";\r\n expected.forEach(function (x) { return (message_1 += \"\\t\" + stringify(x) + \"\\n\"); });\r\n assert(passed, message_1);\r\n }\r\n }\r\n else {\r\n assertDeepEqual(actual, expected);\r\n }\r\n}\r\nexports.observableMatcher = observableMatcher;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/matcher.ts?");

@@ -256,0 +256,0 @@ /***/ }),

8

bundles/rxjs-marbles-jest.umd.js

@@ -154,3 +154,3 @@ (function webpackUniversalModuleDefinition(root, factory) {

"use strict";
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar fast_equals_1 = __webpack_require__(/*! fast-equals */ \"./node_modules/fast-equals/dist/fast-equals.js\");\r\nvar defaultConfiguration = {\r\n assert: defaultAssert,\r\n assertDeepEqual: defaultAssertDeepEqual,\r\n frameworkMatcher: false,\r\n run: true\r\n};\r\nfunction defaults() {\r\n return __assign({}, defaultConfiguration);\r\n}\r\nexports.defaults = defaults;\r\nfunction defaultAssert(value, message) {\r\n if (value) {\r\n return;\r\n }\r\n throw new Error(message);\r\n}\r\nfunction defaultAssertDeepEqual(a, b) {\r\n if (fast_equals_1.deepEqual(a, b)) {\r\n return;\r\n }\r\n throw new Error(\"Expected \" + toString(a) + \" to equal \" + toString(b) + \".\");\r\n}\r\nfunction toString(value) {\r\n if (value === null) {\r\n return \"null\";\r\n }\r\n else if (value === undefined) {\r\n return \"undefined\";\r\n }\r\n return value.toString();\r\n}\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/configuration.ts?");
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar fast_equals_1 = __webpack_require__(/*! fast-equals */ \"./node_modules/fast-equals/dist/fast-equals.js\");\r\nvar defaultConfiguration = {\r\n assert: defaultAssert,\r\n assertDeepEqual: defaultAssertDeepEqual,\r\n frameworkMatcher: false,\r\n run: true\r\n};\r\nfunction defaults() {\r\n return __assign({}, defaultConfiguration);\r\n}\r\nexports.defaults = defaults;\r\nfunction defaultAssert(value, message) {\r\n if (value) {\r\n return;\r\n }\r\n throw new Error(message);\r\n}\r\nfunction defaultAssertDeepEqual(a, b) {\r\n if (fast_equals_1.circularDeepEqual(a, b)) {\r\n return;\r\n }\r\n throw new Error(\"Expected \" + toString(a) + \" to equal \" + toString(b) + \".\");\r\n}\r\nfunction toString(value) {\r\n if (value === null) {\r\n return \"null\";\r\n }\r\n else if (value === undefined) {\r\n return \"undefined\";\r\n }\r\n return value.toString();\r\n}\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/configuration.ts?");

@@ -167,3 +167,3 @@ /***/ }),

"use strict";
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar rxjs_1 = __webpack_require__(/*! rxjs */ \"rxjs\");\r\nvar testing_1 = __webpack_require__(/*! rxjs/testing */ \"rxjs/testing\");\r\nvar args_1 = __webpack_require__(/*! ./args */ \"./source/args.ts\");\r\nvar assert_1 = __webpack_require__(/*! ./assert */ \"./source/assert.ts\");\r\nvar expect_1 = __webpack_require__(/*! ./expect */ \"./source/expect.ts\");\r\nvar matcher_1 = __webpack_require__(/*! ./matcher */ \"./source/matcher.ts\");\r\nvar DeprecatedContext = (function () {\r\n function DeprecatedContext(configuration_) {\r\n this.configuration_ = configuration_;\r\n this.autoFlush = true;\r\n this.bindings_ = [];\r\n this.frameTimeFactor_ = undefined;\r\n this.reframable_ = true;\r\n }\r\n Object.defineProperty(DeprecatedContext.prototype, \"scheduler\", {\r\n get: function () {\r\n var _this = this;\r\n if (!this.scheduler_) {\r\n this.scheduler_ = new testing_1.TestScheduler(function (a, b) {\r\n return matcher_1.observableMatcher(a, b, _this.configuration_.assert, _this.configuration_.assertDeepEqual, _this.configuration_.frameworkMatcher);\r\n });\r\n }\r\n return this.scheduler_;\r\n },\r\n enumerable: true,\r\n configurable: true\r\n });\r\n DeprecatedContext.prototype.bind = function () {\r\n var _this = this;\r\n var schedulers = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n schedulers[_i] = arguments[_i];\r\n }\r\n if (this.bindings_.length !== 0) {\r\n throw new Error(\"Schedulers already bound.\");\r\n }\r\n if (schedulers.length === 0) {\r\n schedulers = [\r\n rxjs_1.animationFrameScheduler,\r\n rxjs_1.asapScheduler,\r\n rxjs_1.asyncScheduler,\r\n rxjs_1.queueScheduler\r\n ];\r\n }\r\n this.bindings_ = schedulers.map(function (instance) {\r\n var now = instance.hasOwnProperty(\"now\") ? instance.now : undefined;\r\n instance.now = function () { return _this.scheduler.now(); };\r\n var schedule = instance.hasOwnProperty(\"schedule\")\r\n ? instance.schedule\r\n : undefined;\r\n instance.schedule = function (work, delay, state) {\r\n return _this.scheduler.schedule(work, delay, state);\r\n };\r\n return { instance: instance, now: now, schedule: schedule };\r\n });\r\n };\r\n DeprecatedContext.prototype.cold = function (marbles, values, error) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n var observable = scheduler.createColdObservable(marbles, values, error);\r\n observable[args_1.argsSymbol] = { error: error, marbles: marbles, values: values };\r\n return observable;\r\n };\r\n DeprecatedContext.prototype.configure = function (configuration) {\r\n if (this.scheduler_) {\r\n throw new Error(\"Scheduler already created; call configure before using other context methods and properties.\");\r\n }\r\n this.configuration_ = __assign({}, this.configuration_, configuration);\r\n };\r\n DeprecatedContext.prototype.equal = function (actual) {\r\n var args = [];\r\n for (var _i = 1; _i < arguments.length; _i++) {\r\n args[_i - 1] = arguments[_i];\r\n }\r\n var scheduler = this.scheduler;\r\n var a0 = args[0], a1 = args[1], a2 = args[2], a3 = args[3];\r\n if (a1 && typeof a1 === \"string\") {\r\n scheduler.expectObservable(actual, a0).toBe(a1, a2, a3);\r\n }\r\n else if (a1 && a1[args_1.argsSymbol]) {\r\n assert_1.assertArgs(a1);\r\n var _a = a1[args_1.argsSymbol], error = _a.error, marbles = _a.marbles, values = _a.values;\r\n scheduler.expectObservable(actual, a0).toBe(marbles, values, error);\r\n }\r\n else if (typeof a0 === \"string\") {\r\n scheduler.expectObservable(actual).toBe(a0, a1, a2);\r\n }\r\n else {\r\n assert_1.assertArgs(a0);\r\n var _b = a0[args_1.argsSymbol], error = _b.error, marbles = _b.marbles, values = _b.values;\r\n scheduler.expectObservable(actual).toBe(marbles, values, error);\r\n }\r\n };\r\n DeprecatedContext.prototype.expect = function (actual, subscription) {\r\n var scheduler = this.scheduler;\r\n return new expect_1.Expect(actual, scheduler, subscription);\r\n };\r\n DeprecatedContext.prototype.flush = function () {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n scheduler.flush();\r\n };\r\n DeprecatedContext.prototype.has = function (actual, expected) {\r\n assert_1.assertSubscriptions(actual);\r\n var scheduler = this.scheduler;\r\n scheduler.expectSubscriptions(actual.subscriptions).toBe(expected);\r\n };\r\n DeprecatedContext.prototype.hot = function (marbles, values, error) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n var observable = scheduler.createHotObservable(marbles, values, error);\r\n observable[args_1.argsSymbol] = { error: error, marbles: marbles, values: values };\r\n return observable;\r\n };\r\n DeprecatedContext.prototype.reframe = function (timePerFrame, maxTime) {\r\n if (!this.reframable_) {\r\n throw new Error(\"Cannot reframe; scheduler already used.\");\r\n }\r\n if (maxTime === undefined) {\r\n maxTime = timePerFrame * 75;\r\n }\r\n this.frameTimeFactor_ =\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor ||\r\n testing_1.TestScheduler.frameTimeFactor;\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor = timePerFrame;\r\n testing_1.TestScheduler.frameTimeFactor = timePerFrame;\r\n var scheduler = this.scheduler;\r\n scheduler.maxFrames = maxTime;\r\n };\r\n DeprecatedContext.prototype.teardown = function () {\r\n try {\r\n if (this.autoFlush) {\r\n this.scheduler.flush();\r\n }\r\n }\r\n finally {\r\n this.bindings_.forEach(function (_a) {\r\n var instance = _a.instance, now = _a.now, schedule = _a.schedule;\r\n if (now) {\r\n instance.now = now;\r\n }\r\n else {\r\n delete instance.now;\r\n }\r\n if (schedule) {\r\n instance.schedule = schedule;\r\n }\r\n else {\r\n delete instance.schedule;\r\n }\r\n });\r\n if (this.frameTimeFactor_) {\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor = this.frameTimeFactor_;\r\n testing_1.TestScheduler.frameTimeFactor = this.frameTimeFactor_;\r\n }\r\n }\r\n };\r\n DeprecatedContext.prototype.time = function (marbles) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n return scheduler.createTime(marbles);\r\n };\r\n return DeprecatedContext;\r\n}());\r\nexports.DeprecatedContext = DeprecatedContext;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/context-deprecated.ts?");
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar rxjs_1 = __webpack_require__(/*! rxjs */ \"rxjs\");\r\nvar testing_1 = __webpack_require__(/*! rxjs/testing */ \"rxjs/testing\");\r\nvar args_1 = __webpack_require__(/*! ./args */ \"./source/args.ts\");\r\nvar assert_1 = __webpack_require__(/*! ./assert */ \"./source/assert.ts\");\r\nvar expect_1 = __webpack_require__(/*! ./expect */ \"./source/expect.ts\");\r\nvar matcher_1 = __webpack_require__(/*! ./matcher */ \"./source/matcher.ts\");\r\nvar DeprecatedContext = (function () {\r\n function DeprecatedContext(configuration_) {\r\n this.configuration_ = configuration_;\r\n this.autoFlush = true;\r\n this.bindings_ = [];\r\n this.frameTimeFactor_ = undefined;\r\n this.reframable_ = true;\r\n }\r\n Object.defineProperty(DeprecatedContext.prototype, \"scheduler\", {\r\n get: function () {\r\n var _this = this;\r\n if (!this.scheduler_) {\r\n this.scheduler_ = new testing_1.TestScheduler(function (actual, expected) {\r\n return matcher_1.observableMatcher(actual, expected, _this.configuration_.assert, _this.configuration_.assertDeepEqual, _this.configuration_.frameworkMatcher);\r\n });\r\n }\r\n return this.scheduler_;\r\n },\r\n enumerable: true,\r\n configurable: true\r\n });\r\n DeprecatedContext.prototype.bind = function () {\r\n var _this = this;\r\n var schedulers = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n schedulers[_i] = arguments[_i];\r\n }\r\n if (this.bindings_.length !== 0) {\r\n throw new Error(\"Schedulers already bound.\");\r\n }\r\n if (schedulers.length === 0) {\r\n schedulers = [\r\n rxjs_1.animationFrameScheduler,\r\n rxjs_1.asapScheduler,\r\n rxjs_1.asyncScheduler,\r\n rxjs_1.queueScheduler\r\n ];\r\n }\r\n this.bindings_ = schedulers.map(function (instance) {\r\n var now = instance.hasOwnProperty(\"now\") ? instance.now : undefined;\r\n instance.now = function () { return _this.scheduler.now(); };\r\n var schedule = instance.hasOwnProperty(\"schedule\")\r\n ? instance.schedule\r\n : undefined;\r\n instance.schedule = function (work, delay, state) {\r\n return _this.scheduler.schedule(work, delay, state);\r\n };\r\n return { instance: instance, now: now, schedule: schedule };\r\n });\r\n };\r\n DeprecatedContext.prototype.cold = function (marbles, values, error) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n var observable = scheduler.createColdObservable(marbles, values, error);\r\n observable[args_1.argsSymbol] = { error: error, marbles: marbles, values: values };\r\n return observable;\r\n };\r\n DeprecatedContext.prototype.configure = function (configuration) {\r\n if (this.scheduler_) {\r\n throw new Error(\"Scheduler already created; call configure before using other context methods and properties.\");\r\n }\r\n this.configuration_ = __assign({}, this.configuration_, configuration);\r\n };\r\n DeprecatedContext.prototype.equal = function (actual) {\r\n var args = [];\r\n for (var _i = 1; _i < arguments.length; _i++) {\r\n args[_i - 1] = arguments[_i];\r\n }\r\n var scheduler = this.scheduler;\r\n var a0 = args[0], a1 = args[1], a2 = args[2], a3 = args[3];\r\n if (a1 && typeof a1 === \"string\") {\r\n scheduler.expectObservable(actual, a0).toBe(a1, a2, a3);\r\n }\r\n else if (a1 && a1[args_1.argsSymbol]) {\r\n assert_1.assertArgs(a1);\r\n var _a = a1[args_1.argsSymbol], error = _a.error, marbles = _a.marbles, values = _a.values;\r\n scheduler.expectObservable(actual, a0).toBe(marbles, values, error);\r\n }\r\n else if (typeof a0 === \"string\") {\r\n scheduler.expectObservable(actual).toBe(a0, a1, a2);\r\n }\r\n else {\r\n assert_1.assertArgs(a0);\r\n var _b = a0[args_1.argsSymbol], error = _b.error, marbles = _b.marbles, values = _b.values;\r\n scheduler.expectObservable(actual).toBe(marbles, values, error);\r\n }\r\n };\r\n DeprecatedContext.prototype.expect = function (actual, subscription) {\r\n var scheduler = this.scheduler;\r\n return new expect_1.Expect(actual, scheduler, subscription);\r\n };\r\n DeprecatedContext.prototype.flush = function () {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n scheduler.flush();\r\n };\r\n DeprecatedContext.prototype.has = function (actual, expected) {\r\n assert_1.assertSubscriptions(actual);\r\n var scheduler = this.scheduler;\r\n scheduler.expectSubscriptions(actual.subscriptions).toBe(expected);\r\n };\r\n DeprecatedContext.prototype.hot = function (marbles, values, error) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n var observable = scheduler.createHotObservable(marbles, values, error);\r\n observable[args_1.argsSymbol] = { error: error, marbles: marbles, values: values };\r\n return observable;\r\n };\r\n DeprecatedContext.prototype.reframe = function (timePerFrame, maxTime) {\r\n if (!this.reframable_) {\r\n throw new Error(\"Cannot reframe; scheduler already used.\");\r\n }\r\n if (maxTime === undefined) {\r\n maxTime = timePerFrame * 75;\r\n }\r\n this.frameTimeFactor_ =\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor ||\r\n testing_1.TestScheduler.frameTimeFactor;\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor = timePerFrame;\r\n testing_1.TestScheduler.frameTimeFactor = timePerFrame;\r\n var scheduler = this.scheduler;\r\n scheduler.maxFrames = maxTime;\r\n };\r\n DeprecatedContext.prototype.teardown = function () {\r\n try {\r\n if (this.autoFlush) {\r\n this.scheduler.flush();\r\n }\r\n }\r\n finally {\r\n this.bindings_.forEach(function (_a) {\r\n var instance = _a.instance, now = _a.now, schedule = _a.schedule;\r\n if (now) {\r\n instance.now = now;\r\n }\r\n else {\r\n delete instance.now;\r\n }\r\n if (schedule) {\r\n instance.schedule = schedule;\r\n }\r\n else {\r\n delete instance.schedule;\r\n }\r\n });\r\n if (this.frameTimeFactor_) {\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor = this.frameTimeFactor_;\r\n testing_1.TestScheduler.frameTimeFactor = this.frameTimeFactor_;\r\n }\r\n }\r\n };\r\n DeprecatedContext.prototype.time = function (marbles) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n return scheduler.createTime(marbles);\r\n };\r\n return DeprecatedContext;\r\n}());\r\nexports.DeprecatedContext = DeprecatedContext;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/context-deprecated.ts?");

@@ -240,3 +240,3 @@ /***/ }),

"use strict";
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar testing_1 = __webpack_require__(/*! rxjs/testing */ \"rxjs/testing\");\r\nvar configuration_1 = __webpack_require__(/*! ./configuration */ \"./source/configuration.ts\");\r\nvar context_deprecated_1 = __webpack_require__(/*! ./context-deprecated */ \"./source/context-deprecated.ts\");\r\nvar context_run_1 = __webpack_require__(/*! ./context-run */ \"./source/context-run.ts\");\r\nvar matcher_1 = __webpack_require__(/*! ./matcher */ \"./source/matcher.ts\");\r\nfunction configure(configurationOrFactory) {\r\n function deriveConfiguration() {\r\n var args = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n args[_i] = arguments[_i];\r\n }\r\n var explicit = typeof configurationOrFactory === \"function\"\r\n ? configurationOrFactory.apply(void 0, args) : configurationOrFactory;\r\n return __assign({}, configuration_1.defaults(), explicit);\r\n }\r\n function _marbles(func) {\r\n var wrapper = function () {\r\n var _this = this;\r\n var rest = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n rest[_i] = arguments[_i];\r\n }\r\n var configuration = deriveConfiguration.apply(void 0, rest);\r\n if (configuration.run) {\r\n var scheduler_1 = new testing_1.TestScheduler(function (a, b) {\r\n return matcher_1.observableMatcher(a, b, configuration.assert, configuration.assertDeepEqual, configuration.frameworkMatcher);\r\n });\r\n return scheduler_1.run(function (helpers) {\r\n return func.call.apply(func, [_this, new context_run_1.RunContext(scheduler_1, helpers)].concat(rest));\r\n });\r\n }\r\n var context = new context_deprecated_1.DeprecatedContext(configuration);\r\n try {\r\n return func.call.apply(func, [this, context].concat(rest));\r\n }\r\n finally {\r\n context.teardown();\r\n }\r\n };\r\n if (func.length > 1) {\r\n return function (first) {\r\n var rest = [];\r\n for (var _i = 1; _i < arguments.length; _i++) {\r\n rest[_i - 1] = arguments[_i];\r\n }\r\n return wrapper.apply(void 0, [first].concat(rest));\r\n };\r\n }\r\n return wrapper;\r\n }\r\n return { marbles: _marbles };\r\n}\r\nexports.configure = configure;\r\nexports.marbles = configure(configuration_1.defaults()).marbles;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/marbles.ts?");
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar testing_1 = __webpack_require__(/*! rxjs/testing */ \"rxjs/testing\");\r\nvar configuration_1 = __webpack_require__(/*! ./configuration */ \"./source/configuration.ts\");\r\nvar context_deprecated_1 = __webpack_require__(/*! ./context-deprecated */ \"./source/context-deprecated.ts\");\r\nvar context_run_1 = __webpack_require__(/*! ./context-run */ \"./source/context-run.ts\");\r\nvar matcher_1 = __webpack_require__(/*! ./matcher */ \"./source/matcher.ts\");\r\nfunction configure(configurationOrFactory) {\r\n function deriveConfiguration() {\r\n var args = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n args[_i] = arguments[_i];\r\n }\r\n var explicit = typeof configurationOrFactory === \"function\"\r\n ? configurationOrFactory.apply(void 0, args) : configurationOrFactory;\r\n return __assign({}, configuration_1.defaults(), explicit);\r\n }\r\n function _marbles(func) {\r\n var wrapper = function () {\r\n var _this = this;\r\n var rest = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n rest[_i] = arguments[_i];\r\n }\r\n var configuration = deriveConfiguration.apply(void 0, rest);\r\n if (configuration.run) {\r\n var scheduler_1 = new testing_1.TestScheduler(function (actual, expected) {\r\n return matcher_1.observableMatcher(actual, expected, configuration.assert, configuration.assertDeepEqual, configuration.frameworkMatcher);\r\n });\r\n return scheduler_1.run(function (helpers) {\r\n return func.call.apply(func, [_this, new context_run_1.RunContext(scheduler_1, helpers)].concat(rest));\r\n });\r\n }\r\n var context = new context_deprecated_1.DeprecatedContext(configuration);\r\n try {\r\n return func.call.apply(func, [this, context].concat(rest));\r\n }\r\n finally {\r\n context.teardown();\r\n }\r\n };\r\n if (func.length > 1) {\r\n return function (first) {\r\n var rest = [];\r\n for (var _i = 1; _i < arguments.length; _i++) {\r\n rest[_i - 1] = arguments[_i];\r\n }\r\n return wrapper.apply(void 0, [first].concat(rest));\r\n };\r\n }\r\n return wrapper;\r\n }\r\n return { marbles: _marbles };\r\n}\r\nexports.configure = configure;\r\nexports.marbles = configure(configuration_1.defaults()).marbles;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/marbles.ts?");

@@ -253,3 +253,3 @@ /***/ }),

"use strict";
eval("\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar fast_equals_1 = __webpack_require__(/*! fast-equals */ \"./node_modules/fast-equals/dist/fast-equals.js\");\r\nfunction stringify(x) {\r\n if (x === undefined) {\r\n return \"undefined\";\r\n }\r\n return JSON.stringify(x, function (key, value) {\r\n if (Array.isArray(value)) {\r\n return (\"[\" +\r\n value.map(function (i) {\r\n return \"\\n\\t\" + stringify(i);\r\n }) +\r\n \"\\n]\");\r\n }\r\n return value;\r\n })\r\n .replace(/\\\\\"/g, '\"')\r\n .replace(/\\\\t/g, \"\\t\")\r\n .replace(/\\\\n/g, \"\\n\");\r\n}\r\nfunction deleteErrorNotificationStack(marble) {\r\n var notification = marble.notification;\r\n if (notification) {\r\n var kind = notification.kind, error = notification.error;\r\n if (kind === \"E\" && error instanceof Error) {\r\n notification.error = { name: error.name, message: error.message };\r\n }\r\n }\r\n return marble;\r\n}\r\nfunction observableMatcher(actual, expected, assert, assertDeepEqual, frameworkMatcher) {\r\n if (Array.isArray(actual) && Array.isArray(expected)) {\r\n actual = actual.map(deleteErrorNotificationStack);\r\n expected = expected.map(deleteErrorNotificationStack);\r\n if (frameworkMatcher) {\r\n assertDeepEqual(actual, expected);\r\n }\r\n else {\r\n var passed = fast_equals_1.deepEqual(actual, expected);\r\n if (passed) {\r\n assert(true, \"\");\r\n return;\r\n }\r\n var message_1 = \"\\nExpected \\n\";\r\n actual.forEach(function (x) { return (message_1 += \"\\t\" + stringify(x) + \"\\n\"); });\r\n message_1 += \"\\t\\nto deep equal \\n\";\r\n expected.forEach(function (x) { return (message_1 += \"\\t\" + stringify(x) + \"\\n\"); });\r\n assert(passed, message_1);\r\n }\r\n }\r\n else {\r\n assertDeepEqual(actual, expected);\r\n }\r\n}\r\nexports.observableMatcher = observableMatcher;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/matcher.ts?");
eval("\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar fast_equals_1 = __webpack_require__(/*! fast-equals */ \"./node_modules/fast-equals/dist/fast-equals.js\");\r\nfunction stringify(x) {\r\n if (x === undefined) {\r\n return \"undefined\";\r\n }\r\n return JSON.stringify(x, function (key, value) {\r\n if (Array.isArray(value)) {\r\n return (\"[\" +\r\n value.map(function (i) {\r\n return \"\\n\\t\" + stringify(i);\r\n }) +\r\n \"\\n]\");\r\n }\r\n return value;\r\n })\r\n .replace(/\\\\\"/g, '\"')\r\n .replace(/\\\\t/g, \"\\t\")\r\n .replace(/\\\\n/g, \"\\n\");\r\n}\r\nfunction deleteErrorNotificationStack(marble) {\r\n var notification = marble.notification;\r\n if (notification) {\r\n var kind = notification.kind, error = notification.error;\r\n if (kind === \"E\" && error instanceof Error) {\r\n notification.error = { name: error.name, message: error.message };\r\n }\r\n }\r\n return marble;\r\n}\r\nfunction observableMatcher(actual, expected, assert, assertDeepEqual, frameworkMatcher) {\r\n if (Array.isArray(actual) && Array.isArray(expected)) {\r\n actual = actual.map(deleteErrorNotificationStack);\r\n expected = expected.map(deleteErrorNotificationStack);\r\n if (frameworkMatcher) {\r\n assertDeepEqual(actual, expected);\r\n }\r\n else {\r\n var passed = fast_equals_1.circularDeepEqual(actual, expected);\r\n if (passed) {\r\n assert(true, \"\");\r\n return;\r\n }\r\n var message_1 = \"\\nExpected \\n\";\r\n actual.forEach(function (x) { return (message_1 += \"\\t\" + stringify(x) + \"\\n\"); });\r\n message_1 += \"\\t\\nto deep equal \\n\";\r\n expected.forEach(function (x) { return (message_1 += \"\\t\" + stringify(x) + \"\\n\"); });\r\n assert(passed, message_1);\r\n }\r\n }\r\n else {\r\n assertDeepEqual(actual, expected);\r\n }\r\n}\r\nexports.observableMatcher = observableMatcher;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/matcher.ts?");

@@ -256,0 +256,0 @@ /***/ }),

8

bundles/rxjs-marbles-mocha.umd.js

@@ -154,3 +154,3 @@ (function webpackUniversalModuleDefinition(root, factory) {

"use strict";
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar fast_equals_1 = __webpack_require__(/*! fast-equals */ \"./node_modules/fast-equals/dist/fast-equals.js\");\r\nvar defaultConfiguration = {\r\n assert: defaultAssert,\r\n assertDeepEqual: defaultAssertDeepEqual,\r\n frameworkMatcher: false,\r\n run: true\r\n};\r\nfunction defaults() {\r\n return __assign({}, defaultConfiguration);\r\n}\r\nexports.defaults = defaults;\r\nfunction defaultAssert(value, message) {\r\n if (value) {\r\n return;\r\n }\r\n throw new Error(message);\r\n}\r\nfunction defaultAssertDeepEqual(a, b) {\r\n if (fast_equals_1.deepEqual(a, b)) {\r\n return;\r\n }\r\n throw new Error(\"Expected \" + toString(a) + \" to equal \" + toString(b) + \".\");\r\n}\r\nfunction toString(value) {\r\n if (value === null) {\r\n return \"null\";\r\n }\r\n else if (value === undefined) {\r\n return \"undefined\";\r\n }\r\n return value.toString();\r\n}\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/configuration.ts?");
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar fast_equals_1 = __webpack_require__(/*! fast-equals */ \"./node_modules/fast-equals/dist/fast-equals.js\");\r\nvar defaultConfiguration = {\r\n assert: defaultAssert,\r\n assertDeepEqual: defaultAssertDeepEqual,\r\n frameworkMatcher: false,\r\n run: true\r\n};\r\nfunction defaults() {\r\n return __assign({}, defaultConfiguration);\r\n}\r\nexports.defaults = defaults;\r\nfunction defaultAssert(value, message) {\r\n if (value) {\r\n return;\r\n }\r\n throw new Error(message);\r\n}\r\nfunction defaultAssertDeepEqual(a, b) {\r\n if (fast_equals_1.circularDeepEqual(a, b)) {\r\n return;\r\n }\r\n throw new Error(\"Expected \" + toString(a) + \" to equal \" + toString(b) + \".\");\r\n}\r\nfunction toString(value) {\r\n if (value === null) {\r\n return \"null\";\r\n }\r\n else if (value === undefined) {\r\n return \"undefined\";\r\n }\r\n return value.toString();\r\n}\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/configuration.ts?");

@@ -167,3 +167,3 @@ /***/ }),

"use strict";
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar rxjs_1 = __webpack_require__(/*! rxjs */ \"rxjs\");\r\nvar testing_1 = __webpack_require__(/*! rxjs/testing */ \"rxjs/testing\");\r\nvar args_1 = __webpack_require__(/*! ./args */ \"./source/args.ts\");\r\nvar assert_1 = __webpack_require__(/*! ./assert */ \"./source/assert.ts\");\r\nvar expect_1 = __webpack_require__(/*! ./expect */ \"./source/expect.ts\");\r\nvar matcher_1 = __webpack_require__(/*! ./matcher */ \"./source/matcher.ts\");\r\nvar DeprecatedContext = (function () {\r\n function DeprecatedContext(configuration_) {\r\n this.configuration_ = configuration_;\r\n this.autoFlush = true;\r\n this.bindings_ = [];\r\n this.frameTimeFactor_ = undefined;\r\n this.reframable_ = true;\r\n }\r\n Object.defineProperty(DeprecatedContext.prototype, \"scheduler\", {\r\n get: function () {\r\n var _this = this;\r\n if (!this.scheduler_) {\r\n this.scheduler_ = new testing_1.TestScheduler(function (a, b) {\r\n return matcher_1.observableMatcher(a, b, _this.configuration_.assert, _this.configuration_.assertDeepEqual, _this.configuration_.frameworkMatcher);\r\n });\r\n }\r\n return this.scheduler_;\r\n },\r\n enumerable: true,\r\n configurable: true\r\n });\r\n DeprecatedContext.prototype.bind = function () {\r\n var _this = this;\r\n var schedulers = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n schedulers[_i] = arguments[_i];\r\n }\r\n if (this.bindings_.length !== 0) {\r\n throw new Error(\"Schedulers already bound.\");\r\n }\r\n if (schedulers.length === 0) {\r\n schedulers = [\r\n rxjs_1.animationFrameScheduler,\r\n rxjs_1.asapScheduler,\r\n rxjs_1.asyncScheduler,\r\n rxjs_1.queueScheduler\r\n ];\r\n }\r\n this.bindings_ = schedulers.map(function (instance) {\r\n var now = instance.hasOwnProperty(\"now\") ? instance.now : undefined;\r\n instance.now = function () { return _this.scheduler.now(); };\r\n var schedule = instance.hasOwnProperty(\"schedule\")\r\n ? instance.schedule\r\n : undefined;\r\n instance.schedule = function (work, delay, state) {\r\n return _this.scheduler.schedule(work, delay, state);\r\n };\r\n return { instance: instance, now: now, schedule: schedule };\r\n });\r\n };\r\n DeprecatedContext.prototype.cold = function (marbles, values, error) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n var observable = scheduler.createColdObservable(marbles, values, error);\r\n observable[args_1.argsSymbol] = { error: error, marbles: marbles, values: values };\r\n return observable;\r\n };\r\n DeprecatedContext.prototype.configure = function (configuration) {\r\n if (this.scheduler_) {\r\n throw new Error(\"Scheduler already created; call configure before using other context methods and properties.\");\r\n }\r\n this.configuration_ = __assign({}, this.configuration_, configuration);\r\n };\r\n DeprecatedContext.prototype.equal = function (actual) {\r\n var args = [];\r\n for (var _i = 1; _i < arguments.length; _i++) {\r\n args[_i - 1] = arguments[_i];\r\n }\r\n var scheduler = this.scheduler;\r\n var a0 = args[0], a1 = args[1], a2 = args[2], a3 = args[3];\r\n if (a1 && typeof a1 === \"string\") {\r\n scheduler.expectObservable(actual, a0).toBe(a1, a2, a3);\r\n }\r\n else if (a1 && a1[args_1.argsSymbol]) {\r\n assert_1.assertArgs(a1);\r\n var _a = a1[args_1.argsSymbol], error = _a.error, marbles = _a.marbles, values = _a.values;\r\n scheduler.expectObservable(actual, a0).toBe(marbles, values, error);\r\n }\r\n else if (typeof a0 === \"string\") {\r\n scheduler.expectObservable(actual).toBe(a0, a1, a2);\r\n }\r\n else {\r\n assert_1.assertArgs(a0);\r\n var _b = a0[args_1.argsSymbol], error = _b.error, marbles = _b.marbles, values = _b.values;\r\n scheduler.expectObservable(actual).toBe(marbles, values, error);\r\n }\r\n };\r\n DeprecatedContext.prototype.expect = function (actual, subscription) {\r\n var scheduler = this.scheduler;\r\n return new expect_1.Expect(actual, scheduler, subscription);\r\n };\r\n DeprecatedContext.prototype.flush = function () {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n scheduler.flush();\r\n };\r\n DeprecatedContext.prototype.has = function (actual, expected) {\r\n assert_1.assertSubscriptions(actual);\r\n var scheduler = this.scheduler;\r\n scheduler.expectSubscriptions(actual.subscriptions).toBe(expected);\r\n };\r\n DeprecatedContext.prototype.hot = function (marbles, values, error) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n var observable = scheduler.createHotObservable(marbles, values, error);\r\n observable[args_1.argsSymbol] = { error: error, marbles: marbles, values: values };\r\n return observable;\r\n };\r\n DeprecatedContext.prototype.reframe = function (timePerFrame, maxTime) {\r\n if (!this.reframable_) {\r\n throw new Error(\"Cannot reframe; scheduler already used.\");\r\n }\r\n if (maxTime === undefined) {\r\n maxTime = timePerFrame * 75;\r\n }\r\n this.frameTimeFactor_ =\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor ||\r\n testing_1.TestScheduler.frameTimeFactor;\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor = timePerFrame;\r\n testing_1.TestScheduler.frameTimeFactor = timePerFrame;\r\n var scheduler = this.scheduler;\r\n scheduler.maxFrames = maxTime;\r\n };\r\n DeprecatedContext.prototype.teardown = function () {\r\n try {\r\n if (this.autoFlush) {\r\n this.scheduler.flush();\r\n }\r\n }\r\n finally {\r\n this.bindings_.forEach(function (_a) {\r\n var instance = _a.instance, now = _a.now, schedule = _a.schedule;\r\n if (now) {\r\n instance.now = now;\r\n }\r\n else {\r\n delete instance.now;\r\n }\r\n if (schedule) {\r\n instance.schedule = schedule;\r\n }\r\n else {\r\n delete instance.schedule;\r\n }\r\n });\r\n if (this.frameTimeFactor_) {\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor = this.frameTimeFactor_;\r\n testing_1.TestScheduler.frameTimeFactor = this.frameTimeFactor_;\r\n }\r\n }\r\n };\r\n DeprecatedContext.prototype.time = function (marbles) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n return scheduler.createTime(marbles);\r\n };\r\n return DeprecatedContext;\r\n}());\r\nexports.DeprecatedContext = DeprecatedContext;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/context-deprecated.ts?");
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar rxjs_1 = __webpack_require__(/*! rxjs */ \"rxjs\");\r\nvar testing_1 = __webpack_require__(/*! rxjs/testing */ \"rxjs/testing\");\r\nvar args_1 = __webpack_require__(/*! ./args */ \"./source/args.ts\");\r\nvar assert_1 = __webpack_require__(/*! ./assert */ \"./source/assert.ts\");\r\nvar expect_1 = __webpack_require__(/*! ./expect */ \"./source/expect.ts\");\r\nvar matcher_1 = __webpack_require__(/*! ./matcher */ \"./source/matcher.ts\");\r\nvar DeprecatedContext = (function () {\r\n function DeprecatedContext(configuration_) {\r\n this.configuration_ = configuration_;\r\n this.autoFlush = true;\r\n this.bindings_ = [];\r\n this.frameTimeFactor_ = undefined;\r\n this.reframable_ = true;\r\n }\r\n Object.defineProperty(DeprecatedContext.prototype, \"scheduler\", {\r\n get: function () {\r\n var _this = this;\r\n if (!this.scheduler_) {\r\n this.scheduler_ = new testing_1.TestScheduler(function (actual, expected) {\r\n return matcher_1.observableMatcher(actual, expected, _this.configuration_.assert, _this.configuration_.assertDeepEqual, _this.configuration_.frameworkMatcher);\r\n });\r\n }\r\n return this.scheduler_;\r\n },\r\n enumerable: true,\r\n configurable: true\r\n });\r\n DeprecatedContext.prototype.bind = function () {\r\n var _this = this;\r\n var schedulers = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n schedulers[_i] = arguments[_i];\r\n }\r\n if (this.bindings_.length !== 0) {\r\n throw new Error(\"Schedulers already bound.\");\r\n }\r\n if (schedulers.length === 0) {\r\n schedulers = [\r\n rxjs_1.animationFrameScheduler,\r\n rxjs_1.asapScheduler,\r\n rxjs_1.asyncScheduler,\r\n rxjs_1.queueScheduler\r\n ];\r\n }\r\n this.bindings_ = schedulers.map(function (instance) {\r\n var now = instance.hasOwnProperty(\"now\") ? instance.now : undefined;\r\n instance.now = function () { return _this.scheduler.now(); };\r\n var schedule = instance.hasOwnProperty(\"schedule\")\r\n ? instance.schedule\r\n : undefined;\r\n instance.schedule = function (work, delay, state) {\r\n return _this.scheduler.schedule(work, delay, state);\r\n };\r\n return { instance: instance, now: now, schedule: schedule };\r\n });\r\n };\r\n DeprecatedContext.prototype.cold = function (marbles, values, error) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n var observable = scheduler.createColdObservable(marbles, values, error);\r\n observable[args_1.argsSymbol] = { error: error, marbles: marbles, values: values };\r\n return observable;\r\n };\r\n DeprecatedContext.prototype.configure = function (configuration) {\r\n if (this.scheduler_) {\r\n throw new Error(\"Scheduler already created; call configure before using other context methods and properties.\");\r\n }\r\n this.configuration_ = __assign({}, this.configuration_, configuration);\r\n };\r\n DeprecatedContext.prototype.equal = function (actual) {\r\n var args = [];\r\n for (var _i = 1; _i < arguments.length; _i++) {\r\n args[_i - 1] = arguments[_i];\r\n }\r\n var scheduler = this.scheduler;\r\n var a0 = args[0], a1 = args[1], a2 = args[2], a3 = args[3];\r\n if (a1 && typeof a1 === \"string\") {\r\n scheduler.expectObservable(actual, a0).toBe(a1, a2, a3);\r\n }\r\n else if (a1 && a1[args_1.argsSymbol]) {\r\n assert_1.assertArgs(a1);\r\n var _a = a1[args_1.argsSymbol], error = _a.error, marbles = _a.marbles, values = _a.values;\r\n scheduler.expectObservable(actual, a0).toBe(marbles, values, error);\r\n }\r\n else if (typeof a0 === \"string\") {\r\n scheduler.expectObservable(actual).toBe(a0, a1, a2);\r\n }\r\n else {\r\n assert_1.assertArgs(a0);\r\n var _b = a0[args_1.argsSymbol], error = _b.error, marbles = _b.marbles, values = _b.values;\r\n scheduler.expectObservable(actual).toBe(marbles, values, error);\r\n }\r\n };\r\n DeprecatedContext.prototype.expect = function (actual, subscription) {\r\n var scheduler = this.scheduler;\r\n return new expect_1.Expect(actual, scheduler, subscription);\r\n };\r\n DeprecatedContext.prototype.flush = function () {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n scheduler.flush();\r\n };\r\n DeprecatedContext.prototype.has = function (actual, expected) {\r\n assert_1.assertSubscriptions(actual);\r\n var scheduler = this.scheduler;\r\n scheduler.expectSubscriptions(actual.subscriptions).toBe(expected);\r\n };\r\n DeprecatedContext.prototype.hot = function (marbles, values, error) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n var observable = scheduler.createHotObservable(marbles, values, error);\r\n observable[args_1.argsSymbol] = { error: error, marbles: marbles, values: values };\r\n return observable;\r\n };\r\n DeprecatedContext.prototype.reframe = function (timePerFrame, maxTime) {\r\n if (!this.reframable_) {\r\n throw new Error(\"Cannot reframe; scheduler already used.\");\r\n }\r\n if (maxTime === undefined) {\r\n maxTime = timePerFrame * 75;\r\n }\r\n this.frameTimeFactor_ =\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor ||\r\n testing_1.TestScheduler.frameTimeFactor;\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor = timePerFrame;\r\n testing_1.TestScheduler.frameTimeFactor = timePerFrame;\r\n var scheduler = this.scheduler;\r\n scheduler.maxFrames = maxTime;\r\n };\r\n DeprecatedContext.prototype.teardown = function () {\r\n try {\r\n if (this.autoFlush) {\r\n this.scheduler.flush();\r\n }\r\n }\r\n finally {\r\n this.bindings_.forEach(function (_a) {\r\n var instance = _a.instance, now = _a.now, schedule = _a.schedule;\r\n if (now) {\r\n instance.now = now;\r\n }\r\n else {\r\n delete instance.now;\r\n }\r\n if (schedule) {\r\n instance.schedule = schedule;\r\n }\r\n else {\r\n delete instance.schedule;\r\n }\r\n });\r\n if (this.frameTimeFactor_) {\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor = this.frameTimeFactor_;\r\n testing_1.TestScheduler.frameTimeFactor = this.frameTimeFactor_;\r\n }\r\n }\r\n };\r\n DeprecatedContext.prototype.time = function (marbles) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n return scheduler.createTime(marbles);\r\n };\r\n return DeprecatedContext;\r\n}());\r\nexports.DeprecatedContext = DeprecatedContext;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/context-deprecated.ts?");

@@ -216,3 +216,3 @@ /***/ }),

"use strict";
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar testing_1 = __webpack_require__(/*! rxjs/testing */ \"rxjs/testing\");\r\nvar configuration_1 = __webpack_require__(/*! ./configuration */ \"./source/configuration.ts\");\r\nvar context_deprecated_1 = __webpack_require__(/*! ./context-deprecated */ \"./source/context-deprecated.ts\");\r\nvar context_run_1 = __webpack_require__(/*! ./context-run */ \"./source/context-run.ts\");\r\nvar matcher_1 = __webpack_require__(/*! ./matcher */ \"./source/matcher.ts\");\r\nfunction configure(configurationOrFactory) {\r\n function deriveConfiguration() {\r\n var args = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n args[_i] = arguments[_i];\r\n }\r\n var explicit = typeof configurationOrFactory === \"function\"\r\n ? configurationOrFactory.apply(void 0, args) : configurationOrFactory;\r\n return __assign({}, configuration_1.defaults(), explicit);\r\n }\r\n function _marbles(func) {\r\n var wrapper = function () {\r\n var _this = this;\r\n var rest = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n rest[_i] = arguments[_i];\r\n }\r\n var configuration = deriveConfiguration.apply(void 0, rest);\r\n if (configuration.run) {\r\n var scheduler_1 = new testing_1.TestScheduler(function (a, b) {\r\n return matcher_1.observableMatcher(a, b, configuration.assert, configuration.assertDeepEqual, configuration.frameworkMatcher);\r\n });\r\n return scheduler_1.run(function (helpers) {\r\n return func.call.apply(func, [_this, new context_run_1.RunContext(scheduler_1, helpers)].concat(rest));\r\n });\r\n }\r\n var context = new context_deprecated_1.DeprecatedContext(configuration);\r\n try {\r\n return func.call.apply(func, [this, context].concat(rest));\r\n }\r\n finally {\r\n context.teardown();\r\n }\r\n };\r\n if (func.length > 1) {\r\n return function (first) {\r\n var rest = [];\r\n for (var _i = 1; _i < arguments.length; _i++) {\r\n rest[_i - 1] = arguments[_i];\r\n }\r\n return wrapper.apply(void 0, [first].concat(rest));\r\n };\r\n }\r\n return wrapper;\r\n }\r\n return { marbles: _marbles };\r\n}\r\nexports.configure = configure;\r\nexports.marbles = configure(configuration_1.defaults()).marbles;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/marbles.ts?");
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar testing_1 = __webpack_require__(/*! rxjs/testing */ \"rxjs/testing\");\r\nvar configuration_1 = __webpack_require__(/*! ./configuration */ \"./source/configuration.ts\");\r\nvar context_deprecated_1 = __webpack_require__(/*! ./context-deprecated */ \"./source/context-deprecated.ts\");\r\nvar context_run_1 = __webpack_require__(/*! ./context-run */ \"./source/context-run.ts\");\r\nvar matcher_1 = __webpack_require__(/*! ./matcher */ \"./source/matcher.ts\");\r\nfunction configure(configurationOrFactory) {\r\n function deriveConfiguration() {\r\n var args = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n args[_i] = arguments[_i];\r\n }\r\n var explicit = typeof configurationOrFactory === \"function\"\r\n ? configurationOrFactory.apply(void 0, args) : configurationOrFactory;\r\n return __assign({}, configuration_1.defaults(), explicit);\r\n }\r\n function _marbles(func) {\r\n var wrapper = function () {\r\n var _this = this;\r\n var rest = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n rest[_i] = arguments[_i];\r\n }\r\n var configuration = deriveConfiguration.apply(void 0, rest);\r\n if (configuration.run) {\r\n var scheduler_1 = new testing_1.TestScheduler(function (actual, expected) {\r\n return matcher_1.observableMatcher(actual, expected, configuration.assert, configuration.assertDeepEqual, configuration.frameworkMatcher);\r\n });\r\n return scheduler_1.run(function (helpers) {\r\n return func.call.apply(func, [_this, new context_run_1.RunContext(scheduler_1, helpers)].concat(rest));\r\n });\r\n }\r\n var context = new context_deprecated_1.DeprecatedContext(configuration);\r\n try {\r\n return func.call.apply(func, [this, context].concat(rest));\r\n }\r\n finally {\r\n context.teardown();\r\n }\r\n };\r\n if (func.length > 1) {\r\n return function (first) {\r\n var rest = [];\r\n for (var _i = 1; _i < arguments.length; _i++) {\r\n rest[_i - 1] = arguments[_i];\r\n }\r\n return wrapper.apply(void 0, [first].concat(rest));\r\n };\r\n }\r\n return wrapper;\r\n }\r\n return { marbles: _marbles };\r\n}\r\nexports.configure = configure;\r\nexports.marbles = configure(configuration_1.defaults()).marbles;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/marbles.ts?");

@@ -229,3 +229,3 @@ /***/ }),

"use strict";
eval("\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar fast_equals_1 = __webpack_require__(/*! fast-equals */ \"./node_modules/fast-equals/dist/fast-equals.js\");\r\nfunction stringify(x) {\r\n if (x === undefined) {\r\n return \"undefined\";\r\n }\r\n return JSON.stringify(x, function (key, value) {\r\n if (Array.isArray(value)) {\r\n return (\"[\" +\r\n value.map(function (i) {\r\n return \"\\n\\t\" + stringify(i);\r\n }) +\r\n \"\\n]\");\r\n }\r\n return value;\r\n })\r\n .replace(/\\\\\"/g, '\"')\r\n .replace(/\\\\t/g, \"\\t\")\r\n .replace(/\\\\n/g, \"\\n\");\r\n}\r\nfunction deleteErrorNotificationStack(marble) {\r\n var notification = marble.notification;\r\n if (notification) {\r\n var kind = notification.kind, error = notification.error;\r\n if (kind === \"E\" && error instanceof Error) {\r\n notification.error = { name: error.name, message: error.message };\r\n }\r\n }\r\n return marble;\r\n}\r\nfunction observableMatcher(actual, expected, assert, assertDeepEqual, frameworkMatcher) {\r\n if (Array.isArray(actual) && Array.isArray(expected)) {\r\n actual = actual.map(deleteErrorNotificationStack);\r\n expected = expected.map(deleteErrorNotificationStack);\r\n if (frameworkMatcher) {\r\n assertDeepEqual(actual, expected);\r\n }\r\n else {\r\n var passed = fast_equals_1.deepEqual(actual, expected);\r\n if (passed) {\r\n assert(true, \"\");\r\n return;\r\n }\r\n var message_1 = \"\\nExpected \\n\";\r\n actual.forEach(function (x) { return (message_1 += \"\\t\" + stringify(x) + \"\\n\"); });\r\n message_1 += \"\\t\\nto deep equal \\n\";\r\n expected.forEach(function (x) { return (message_1 += \"\\t\" + stringify(x) + \"\\n\"); });\r\n assert(passed, message_1);\r\n }\r\n }\r\n else {\r\n assertDeepEqual(actual, expected);\r\n }\r\n}\r\nexports.observableMatcher = observableMatcher;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/matcher.ts?");
eval("\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar fast_equals_1 = __webpack_require__(/*! fast-equals */ \"./node_modules/fast-equals/dist/fast-equals.js\");\r\nfunction stringify(x) {\r\n if (x === undefined) {\r\n return \"undefined\";\r\n }\r\n return JSON.stringify(x, function (key, value) {\r\n if (Array.isArray(value)) {\r\n return (\"[\" +\r\n value.map(function (i) {\r\n return \"\\n\\t\" + stringify(i);\r\n }) +\r\n \"\\n]\");\r\n }\r\n return value;\r\n })\r\n .replace(/\\\\\"/g, '\"')\r\n .replace(/\\\\t/g, \"\\t\")\r\n .replace(/\\\\n/g, \"\\n\");\r\n}\r\nfunction deleteErrorNotificationStack(marble) {\r\n var notification = marble.notification;\r\n if (notification) {\r\n var kind = notification.kind, error = notification.error;\r\n if (kind === \"E\" && error instanceof Error) {\r\n notification.error = { name: error.name, message: error.message };\r\n }\r\n }\r\n return marble;\r\n}\r\nfunction observableMatcher(actual, expected, assert, assertDeepEqual, frameworkMatcher) {\r\n if (Array.isArray(actual) && Array.isArray(expected)) {\r\n actual = actual.map(deleteErrorNotificationStack);\r\n expected = expected.map(deleteErrorNotificationStack);\r\n if (frameworkMatcher) {\r\n assertDeepEqual(actual, expected);\r\n }\r\n else {\r\n var passed = fast_equals_1.circularDeepEqual(actual, expected);\r\n if (passed) {\r\n assert(true, \"\");\r\n return;\r\n }\r\n var message_1 = \"\\nExpected \\n\";\r\n actual.forEach(function (x) { return (message_1 += \"\\t\" + stringify(x) + \"\\n\"); });\r\n message_1 += \"\\t\\nto deep equal \\n\";\r\n expected.forEach(function (x) { return (message_1 += \"\\t\" + stringify(x) + \"\\n\"); });\r\n assert(passed, message_1);\r\n }\r\n }\r\n else {\r\n assertDeepEqual(actual, expected);\r\n }\r\n}\r\nexports.observableMatcher = observableMatcher;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/matcher.ts?");

@@ -232,0 +232,0 @@ /***/ }),

8

bundles/rxjs-marbles-tape.umd.js

@@ -154,3 +154,3 @@ (function webpackUniversalModuleDefinition(root, factory) {

"use strict";
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar fast_equals_1 = __webpack_require__(/*! fast-equals */ \"./node_modules/fast-equals/dist/fast-equals.js\");\r\nvar defaultConfiguration = {\r\n assert: defaultAssert,\r\n assertDeepEqual: defaultAssertDeepEqual,\r\n frameworkMatcher: false,\r\n run: true\r\n};\r\nfunction defaults() {\r\n return __assign({}, defaultConfiguration);\r\n}\r\nexports.defaults = defaults;\r\nfunction defaultAssert(value, message) {\r\n if (value) {\r\n return;\r\n }\r\n throw new Error(message);\r\n}\r\nfunction defaultAssertDeepEqual(a, b) {\r\n if (fast_equals_1.deepEqual(a, b)) {\r\n return;\r\n }\r\n throw new Error(\"Expected \" + toString(a) + \" to equal \" + toString(b) + \".\");\r\n}\r\nfunction toString(value) {\r\n if (value === null) {\r\n return \"null\";\r\n }\r\n else if (value === undefined) {\r\n return \"undefined\";\r\n }\r\n return value.toString();\r\n}\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/configuration.ts?");
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar fast_equals_1 = __webpack_require__(/*! fast-equals */ \"./node_modules/fast-equals/dist/fast-equals.js\");\r\nvar defaultConfiguration = {\r\n assert: defaultAssert,\r\n assertDeepEqual: defaultAssertDeepEqual,\r\n frameworkMatcher: false,\r\n run: true\r\n};\r\nfunction defaults() {\r\n return __assign({}, defaultConfiguration);\r\n}\r\nexports.defaults = defaults;\r\nfunction defaultAssert(value, message) {\r\n if (value) {\r\n return;\r\n }\r\n throw new Error(message);\r\n}\r\nfunction defaultAssertDeepEqual(a, b) {\r\n if (fast_equals_1.circularDeepEqual(a, b)) {\r\n return;\r\n }\r\n throw new Error(\"Expected \" + toString(a) + \" to equal \" + toString(b) + \".\");\r\n}\r\nfunction toString(value) {\r\n if (value === null) {\r\n return \"null\";\r\n }\r\n else if (value === undefined) {\r\n return \"undefined\";\r\n }\r\n return value.toString();\r\n}\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/configuration.ts?");

@@ -167,3 +167,3 @@ /***/ }),

"use strict";
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar rxjs_1 = __webpack_require__(/*! rxjs */ \"rxjs\");\r\nvar testing_1 = __webpack_require__(/*! rxjs/testing */ \"rxjs/testing\");\r\nvar args_1 = __webpack_require__(/*! ./args */ \"./source/args.ts\");\r\nvar assert_1 = __webpack_require__(/*! ./assert */ \"./source/assert.ts\");\r\nvar expect_1 = __webpack_require__(/*! ./expect */ \"./source/expect.ts\");\r\nvar matcher_1 = __webpack_require__(/*! ./matcher */ \"./source/matcher.ts\");\r\nvar DeprecatedContext = (function () {\r\n function DeprecatedContext(configuration_) {\r\n this.configuration_ = configuration_;\r\n this.autoFlush = true;\r\n this.bindings_ = [];\r\n this.frameTimeFactor_ = undefined;\r\n this.reframable_ = true;\r\n }\r\n Object.defineProperty(DeprecatedContext.prototype, \"scheduler\", {\r\n get: function () {\r\n var _this = this;\r\n if (!this.scheduler_) {\r\n this.scheduler_ = new testing_1.TestScheduler(function (a, b) {\r\n return matcher_1.observableMatcher(a, b, _this.configuration_.assert, _this.configuration_.assertDeepEqual, _this.configuration_.frameworkMatcher);\r\n });\r\n }\r\n return this.scheduler_;\r\n },\r\n enumerable: true,\r\n configurable: true\r\n });\r\n DeprecatedContext.prototype.bind = function () {\r\n var _this = this;\r\n var schedulers = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n schedulers[_i] = arguments[_i];\r\n }\r\n if (this.bindings_.length !== 0) {\r\n throw new Error(\"Schedulers already bound.\");\r\n }\r\n if (schedulers.length === 0) {\r\n schedulers = [\r\n rxjs_1.animationFrameScheduler,\r\n rxjs_1.asapScheduler,\r\n rxjs_1.asyncScheduler,\r\n rxjs_1.queueScheduler\r\n ];\r\n }\r\n this.bindings_ = schedulers.map(function (instance) {\r\n var now = instance.hasOwnProperty(\"now\") ? instance.now : undefined;\r\n instance.now = function () { return _this.scheduler.now(); };\r\n var schedule = instance.hasOwnProperty(\"schedule\")\r\n ? instance.schedule\r\n : undefined;\r\n instance.schedule = function (work, delay, state) {\r\n return _this.scheduler.schedule(work, delay, state);\r\n };\r\n return { instance: instance, now: now, schedule: schedule };\r\n });\r\n };\r\n DeprecatedContext.prototype.cold = function (marbles, values, error) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n var observable = scheduler.createColdObservable(marbles, values, error);\r\n observable[args_1.argsSymbol] = { error: error, marbles: marbles, values: values };\r\n return observable;\r\n };\r\n DeprecatedContext.prototype.configure = function (configuration) {\r\n if (this.scheduler_) {\r\n throw new Error(\"Scheduler already created; call configure before using other context methods and properties.\");\r\n }\r\n this.configuration_ = __assign({}, this.configuration_, configuration);\r\n };\r\n DeprecatedContext.prototype.equal = function (actual) {\r\n var args = [];\r\n for (var _i = 1; _i < arguments.length; _i++) {\r\n args[_i - 1] = arguments[_i];\r\n }\r\n var scheduler = this.scheduler;\r\n var a0 = args[0], a1 = args[1], a2 = args[2], a3 = args[3];\r\n if (a1 && typeof a1 === \"string\") {\r\n scheduler.expectObservable(actual, a0).toBe(a1, a2, a3);\r\n }\r\n else if (a1 && a1[args_1.argsSymbol]) {\r\n assert_1.assertArgs(a1);\r\n var _a = a1[args_1.argsSymbol], error = _a.error, marbles = _a.marbles, values = _a.values;\r\n scheduler.expectObservable(actual, a0).toBe(marbles, values, error);\r\n }\r\n else if (typeof a0 === \"string\") {\r\n scheduler.expectObservable(actual).toBe(a0, a1, a2);\r\n }\r\n else {\r\n assert_1.assertArgs(a0);\r\n var _b = a0[args_1.argsSymbol], error = _b.error, marbles = _b.marbles, values = _b.values;\r\n scheduler.expectObservable(actual).toBe(marbles, values, error);\r\n }\r\n };\r\n DeprecatedContext.prototype.expect = function (actual, subscription) {\r\n var scheduler = this.scheduler;\r\n return new expect_1.Expect(actual, scheduler, subscription);\r\n };\r\n DeprecatedContext.prototype.flush = function () {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n scheduler.flush();\r\n };\r\n DeprecatedContext.prototype.has = function (actual, expected) {\r\n assert_1.assertSubscriptions(actual);\r\n var scheduler = this.scheduler;\r\n scheduler.expectSubscriptions(actual.subscriptions).toBe(expected);\r\n };\r\n DeprecatedContext.prototype.hot = function (marbles, values, error) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n var observable = scheduler.createHotObservable(marbles, values, error);\r\n observable[args_1.argsSymbol] = { error: error, marbles: marbles, values: values };\r\n return observable;\r\n };\r\n DeprecatedContext.prototype.reframe = function (timePerFrame, maxTime) {\r\n if (!this.reframable_) {\r\n throw new Error(\"Cannot reframe; scheduler already used.\");\r\n }\r\n if (maxTime === undefined) {\r\n maxTime = timePerFrame * 75;\r\n }\r\n this.frameTimeFactor_ =\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor ||\r\n testing_1.TestScheduler.frameTimeFactor;\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor = timePerFrame;\r\n testing_1.TestScheduler.frameTimeFactor = timePerFrame;\r\n var scheduler = this.scheduler;\r\n scheduler.maxFrames = maxTime;\r\n };\r\n DeprecatedContext.prototype.teardown = function () {\r\n try {\r\n if (this.autoFlush) {\r\n this.scheduler.flush();\r\n }\r\n }\r\n finally {\r\n this.bindings_.forEach(function (_a) {\r\n var instance = _a.instance, now = _a.now, schedule = _a.schedule;\r\n if (now) {\r\n instance.now = now;\r\n }\r\n else {\r\n delete instance.now;\r\n }\r\n if (schedule) {\r\n instance.schedule = schedule;\r\n }\r\n else {\r\n delete instance.schedule;\r\n }\r\n });\r\n if (this.frameTimeFactor_) {\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor = this.frameTimeFactor_;\r\n testing_1.TestScheduler.frameTimeFactor = this.frameTimeFactor_;\r\n }\r\n }\r\n };\r\n DeprecatedContext.prototype.time = function (marbles) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n return scheduler.createTime(marbles);\r\n };\r\n return DeprecatedContext;\r\n}());\r\nexports.DeprecatedContext = DeprecatedContext;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/context-deprecated.ts?");
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar rxjs_1 = __webpack_require__(/*! rxjs */ \"rxjs\");\r\nvar testing_1 = __webpack_require__(/*! rxjs/testing */ \"rxjs/testing\");\r\nvar args_1 = __webpack_require__(/*! ./args */ \"./source/args.ts\");\r\nvar assert_1 = __webpack_require__(/*! ./assert */ \"./source/assert.ts\");\r\nvar expect_1 = __webpack_require__(/*! ./expect */ \"./source/expect.ts\");\r\nvar matcher_1 = __webpack_require__(/*! ./matcher */ \"./source/matcher.ts\");\r\nvar DeprecatedContext = (function () {\r\n function DeprecatedContext(configuration_) {\r\n this.configuration_ = configuration_;\r\n this.autoFlush = true;\r\n this.bindings_ = [];\r\n this.frameTimeFactor_ = undefined;\r\n this.reframable_ = true;\r\n }\r\n Object.defineProperty(DeprecatedContext.prototype, \"scheduler\", {\r\n get: function () {\r\n var _this = this;\r\n if (!this.scheduler_) {\r\n this.scheduler_ = new testing_1.TestScheduler(function (actual, expected) {\r\n return matcher_1.observableMatcher(actual, expected, _this.configuration_.assert, _this.configuration_.assertDeepEqual, _this.configuration_.frameworkMatcher);\r\n });\r\n }\r\n return this.scheduler_;\r\n },\r\n enumerable: true,\r\n configurable: true\r\n });\r\n DeprecatedContext.prototype.bind = function () {\r\n var _this = this;\r\n var schedulers = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n schedulers[_i] = arguments[_i];\r\n }\r\n if (this.bindings_.length !== 0) {\r\n throw new Error(\"Schedulers already bound.\");\r\n }\r\n if (schedulers.length === 0) {\r\n schedulers = [\r\n rxjs_1.animationFrameScheduler,\r\n rxjs_1.asapScheduler,\r\n rxjs_1.asyncScheduler,\r\n rxjs_1.queueScheduler\r\n ];\r\n }\r\n this.bindings_ = schedulers.map(function (instance) {\r\n var now = instance.hasOwnProperty(\"now\") ? instance.now : undefined;\r\n instance.now = function () { return _this.scheduler.now(); };\r\n var schedule = instance.hasOwnProperty(\"schedule\")\r\n ? instance.schedule\r\n : undefined;\r\n instance.schedule = function (work, delay, state) {\r\n return _this.scheduler.schedule(work, delay, state);\r\n };\r\n return { instance: instance, now: now, schedule: schedule };\r\n });\r\n };\r\n DeprecatedContext.prototype.cold = function (marbles, values, error) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n var observable = scheduler.createColdObservable(marbles, values, error);\r\n observable[args_1.argsSymbol] = { error: error, marbles: marbles, values: values };\r\n return observable;\r\n };\r\n DeprecatedContext.prototype.configure = function (configuration) {\r\n if (this.scheduler_) {\r\n throw new Error(\"Scheduler already created; call configure before using other context methods and properties.\");\r\n }\r\n this.configuration_ = __assign({}, this.configuration_, configuration);\r\n };\r\n DeprecatedContext.prototype.equal = function (actual) {\r\n var args = [];\r\n for (var _i = 1; _i < arguments.length; _i++) {\r\n args[_i - 1] = arguments[_i];\r\n }\r\n var scheduler = this.scheduler;\r\n var a0 = args[0], a1 = args[1], a2 = args[2], a3 = args[3];\r\n if (a1 && typeof a1 === \"string\") {\r\n scheduler.expectObservable(actual, a0).toBe(a1, a2, a3);\r\n }\r\n else if (a1 && a1[args_1.argsSymbol]) {\r\n assert_1.assertArgs(a1);\r\n var _a = a1[args_1.argsSymbol], error = _a.error, marbles = _a.marbles, values = _a.values;\r\n scheduler.expectObservable(actual, a0).toBe(marbles, values, error);\r\n }\r\n else if (typeof a0 === \"string\") {\r\n scheduler.expectObservable(actual).toBe(a0, a1, a2);\r\n }\r\n else {\r\n assert_1.assertArgs(a0);\r\n var _b = a0[args_1.argsSymbol], error = _b.error, marbles = _b.marbles, values = _b.values;\r\n scheduler.expectObservable(actual).toBe(marbles, values, error);\r\n }\r\n };\r\n DeprecatedContext.prototype.expect = function (actual, subscription) {\r\n var scheduler = this.scheduler;\r\n return new expect_1.Expect(actual, scheduler, subscription);\r\n };\r\n DeprecatedContext.prototype.flush = function () {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n scheduler.flush();\r\n };\r\n DeprecatedContext.prototype.has = function (actual, expected) {\r\n assert_1.assertSubscriptions(actual);\r\n var scheduler = this.scheduler;\r\n scheduler.expectSubscriptions(actual.subscriptions).toBe(expected);\r\n };\r\n DeprecatedContext.prototype.hot = function (marbles, values, error) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n var observable = scheduler.createHotObservable(marbles, values, error);\r\n observable[args_1.argsSymbol] = { error: error, marbles: marbles, values: values };\r\n return observable;\r\n };\r\n DeprecatedContext.prototype.reframe = function (timePerFrame, maxTime) {\r\n if (!this.reframable_) {\r\n throw new Error(\"Cannot reframe; scheduler already used.\");\r\n }\r\n if (maxTime === undefined) {\r\n maxTime = timePerFrame * 75;\r\n }\r\n this.frameTimeFactor_ =\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor ||\r\n testing_1.TestScheduler.frameTimeFactor;\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor = timePerFrame;\r\n testing_1.TestScheduler.frameTimeFactor = timePerFrame;\r\n var scheduler = this.scheduler;\r\n scheduler.maxFrames = maxTime;\r\n };\r\n DeprecatedContext.prototype.teardown = function () {\r\n try {\r\n if (this.autoFlush) {\r\n this.scheduler.flush();\r\n }\r\n }\r\n finally {\r\n this.bindings_.forEach(function (_a) {\r\n var instance = _a.instance, now = _a.now, schedule = _a.schedule;\r\n if (now) {\r\n instance.now = now;\r\n }\r\n else {\r\n delete instance.now;\r\n }\r\n if (schedule) {\r\n instance.schedule = schedule;\r\n }\r\n else {\r\n delete instance.schedule;\r\n }\r\n });\r\n if (this.frameTimeFactor_) {\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor = this.frameTimeFactor_;\r\n testing_1.TestScheduler.frameTimeFactor = this.frameTimeFactor_;\r\n }\r\n }\r\n };\r\n DeprecatedContext.prototype.time = function (marbles) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n return scheduler.createTime(marbles);\r\n };\r\n return DeprecatedContext;\r\n}());\r\nexports.DeprecatedContext = DeprecatedContext;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/context-deprecated.ts?");

@@ -216,3 +216,3 @@ /***/ }),

"use strict";
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar testing_1 = __webpack_require__(/*! rxjs/testing */ \"rxjs/testing\");\r\nvar configuration_1 = __webpack_require__(/*! ./configuration */ \"./source/configuration.ts\");\r\nvar context_deprecated_1 = __webpack_require__(/*! ./context-deprecated */ \"./source/context-deprecated.ts\");\r\nvar context_run_1 = __webpack_require__(/*! ./context-run */ \"./source/context-run.ts\");\r\nvar matcher_1 = __webpack_require__(/*! ./matcher */ \"./source/matcher.ts\");\r\nfunction configure(configurationOrFactory) {\r\n function deriveConfiguration() {\r\n var args = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n args[_i] = arguments[_i];\r\n }\r\n var explicit = typeof configurationOrFactory === \"function\"\r\n ? configurationOrFactory.apply(void 0, args) : configurationOrFactory;\r\n return __assign({}, configuration_1.defaults(), explicit);\r\n }\r\n function _marbles(func) {\r\n var wrapper = function () {\r\n var _this = this;\r\n var rest = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n rest[_i] = arguments[_i];\r\n }\r\n var configuration = deriveConfiguration.apply(void 0, rest);\r\n if (configuration.run) {\r\n var scheduler_1 = new testing_1.TestScheduler(function (a, b) {\r\n return matcher_1.observableMatcher(a, b, configuration.assert, configuration.assertDeepEqual, configuration.frameworkMatcher);\r\n });\r\n return scheduler_1.run(function (helpers) {\r\n return func.call.apply(func, [_this, new context_run_1.RunContext(scheduler_1, helpers)].concat(rest));\r\n });\r\n }\r\n var context = new context_deprecated_1.DeprecatedContext(configuration);\r\n try {\r\n return func.call.apply(func, [this, context].concat(rest));\r\n }\r\n finally {\r\n context.teardown();\r\n }\r\n };\r\n if (func.length > 1) {\r\n return function (first) {\r\n var rest = [];\r\n for (var _i = 1; _i < arguments.length; _i++) {\r\n rest[_i - 1] = arguments[_i];\r\n }\r\n return wrapper.apply(void 0, [first].concat(rest));\r\n };\r\n }\r\n return wrapper;\r\n }\r\n return { marbles: _marbles };\r\n}\r\nexports.configure = configure;\r\nexports.marbles = configure(configuration_1.defaults()).marbles;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/marbles.ts?");
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar testing_1 = __webpack_require__(/*! rxjs/testing */ \"rxjs/testing\");\r\nvar configuration_1 = __webpack_require__(/*! ./configuration */ \"./source/configuration.ts\");\r\nvar context_deprecated_1 = __webpack_require__(/*! ./context-deprecated */ \"./source/context-deprecated.ts\");\r\nvar context_run_1 = __webpack_require__(/*! ./context-run */ \"./source/context-run.ts\");\r\nvar matcher_1 = __webpack_require__(/*! ./matcher */ \"./source/matcher.ts\");\r\nfunction configure(configurationOrFactory) {\r\n function deriveConfiguration() {\r\n var args = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n args[_i] = arguments[_i];\r\n }\r\n var explicit = typeof configurationOrFactory === \"function\"\r\n ? configurationOrFactory.apply(void 0, args) : configurationOrFactory;\r\n return __assign({}, configuration_1.defaults(), explicit);\r\n }\r\n function _marbles(func) {\r\n var wrapper = function () {\r\n var _this = this;\r\n var rest = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n rest[_i] = arguments[_i];\r\n }\r\n var configuration = deriveConfiguration.apply(void 0, rest);\r\n if (configuration.run) {\r\n var scheduler_1 = new testing_1.TestScheduler(function (actual, expected) {\r\n return matcher_1.observableMatcher(actual, expected, configuration.assert, configuration.assertDeepEqual, configuration.frameworkMatcher);\r\n });\r\n return scheduler_1.run(function (helpers) {\r\n return func.call.apply(func, [_this, new context_run_1.RunContext(scheduler_1, helpers)].concat(rest));\r\n });\r\n }\r\n var context = new context_deprecated_1.DeprecatedContext(configuration);\r\n try {\r\n return func.call.apply(func, [this, context].concat(rest));\r\n }\r\n finally {\r\n context.teardown();\r\n }\r\n };\r\n if (func.length > 1) {\r\n return function (first) {\r\n var rest = [];\r\n for (var _i = 1; _i < arguments.length; _i++) {\r\n rest[_i - 1] = arguments[_i];\r\n }\r\n return wrapper.apply(void 0, [first].concat(rest));\r\n };\r\n }\r\n return wrapper;\r\n }\r\n return { marbles: _marbles };\r\n}\r\nexports.configure = configure;\r\nexports.marbles = configure(configuration_1.defaults()).marbles;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/marbles.ts?");

@@ -229,3 +229,3 @@ /***/ }),

"use strict";
eval("\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar fast_equals_1 = __webpack_require__(/*! fast-equals */ \"./node_modules/fast-equals/dist/fast-equals.js\");\r\nfunction stringify(x) {\r\n if (x === undefined) {\r\n return \"undefined\";\r\n }\r\n return JSON.stringify(x, function (key, value) {\r\n if (Array.isArray(value)) {\r\n return (\"[\" +\r\n value.map(function (i) {\r\n return \"\\n\\t\" + stringify(i);\r\n }) +\r\n \"\\n]\");\r\n }\r\n return value;\r\n })\r\n .replace(/\\\\\"/g, '\"')\r\n .replace(/\\\\t/g, \"\\t\")\r\n .replace(/\\\\n/g, \"\\n\");\r\n}\r\nfunction deleteErrorNotificationStack(marble) {\r\n var notification = marble.notification;\r\n if (notification) {\r\n var kind = notification.kind, error = notification.error;\r\n if (kind === \"E\" && error instanceof Error) {\r\n notification.error = { name: error.name, message: error.message };\r\n }\r\n }\r\n return marble;\r\n}\r\nfunction observableMatcher(actual, expected, assert, assertDeepEqual, frameworkMatcher) {\r\n if (Array.isArray(actual) && Array.isArray(expected)) {\r\n actual = actual.map(deleteErrorNotificationStack);\r\n expected = expected.map(deleteErrorNotificationStack);\r\n if (frameworkMatcher) {\r\n assertDeepEqual(actual, expected);\r\n }\r\n else {\r\n var passed = fast_equals_1.deepEqual(actual, expected);\r\n if (passed) {\r\n assert(true, \"\");\r\n return;\r\n }\r\n var message_1 = \"\\nExpected \\n\";\r\n actual.forEach(function (x) { return (message_1 += \"\\t\" + stringify(x) + \"\\n\"); });\r\n message_1 += \"\\t\\nto deep equal \\n\";\r\n expected.forEach(function (x) { return (message_1 += \"\\t\" + stringify(x) + \"\\n\"); });\r\n assert(passed, message_1);\r\n }\r\n }\r\n else {\r\n assertDeepEqual(actual, expected);\r\n }\r\n}\r\nexports.observableMatcher = observableMatcher;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/matcher.ts?");
eval("\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar fast_equals_1 = __webpack_require__(/*! fast-equals */ \"./node_modules/fast-equals/dist/fast-equals.js\");\r\nfunction stringify(x) {\r\n if (x === undefined) {\r\n return \"undefined\";\r\n }\r\n return JSON.stringify(x, function (key, value) {\r\n if (Array.isArray(value)) {\r\n return (\"[\" +\r\n value.map(function (i) {\r\n return \"\\n\\t\" + stringify(i);\r\n }) +\r\n \"\\n]\");\r\n }\r\n return value;\r\n })\r\n .replace(/\\\\\"/g, '\"')\r\n .replace(/\\\\t/g, \"\\t\")\r\n .replace(/\\\\n/g, \"\\n\");\r\n}\r\nfunction deleteErrorNotificationStack(marble) {\r\n var notification = marble.notification;\r\n if (notification) {\r\n var kind = notification.kind, error = notification.error;\r\n if (kind === \"E\" && error instanceof Error) {\r\n notification.error = { name: error.name, message: error.message };\r\n }\r\n }\r\n return marble;\r\n}\r\nfunction observableMatcher(actual, expected, assert, assertDeepEqual, frameworkMatcher) {\r\n if (Array.isArray(actual) && Array.isArray(expected)) {\r\n actual = actual.map(deleteErrorNotificationStack);\r\n expected = expected.map(deleteErrorNotificationStack);\r\n if (frameworkMatcher) {\r\n assertDeepEqual(actual, expected);\r\n }\r\n else {\r\n var passed = fast_equals_1.circularDeepEqual(actual, expected);\r\n if (passed) {\r\n assert(true, \"\");\r\n return;\r\n }\r\n var message_1 = \"\\nExpected \\n\";\r\n actual.forEach(function (x) { return (message_1 += \"\\t\" + stringify(x) + \"\\n\"); });\r\n message_1 += \"\\t\\nto deep equal \\n\";\r\n expected.forEach(function (x) { return (message_1 += \"\\t\" + stringify(x) + \"\\n\"); });\r\n assert(passed, message_1);\r\n }\r\n }\r\n else {\r\n assertDeepEqual(actual, expected);\r\n }\r\n}\r\nexports.observableMatcher = observableMatcher;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/matcher.ts?");

@@ -232,0 +232,0 @@ /***/ }),

8

bundles/rxjs-marbles.umd.js

@@ -142,3 +142,3 @@ (function webpackUniversalModuleDefinition(root, factory) {

"use strict";
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar fast_equals_1 = __webpack_require__(/*! fast-equals */ \"./node_modules/fast-equals/dist/fast-equals.js\");\r\nvar defaultConfiguration = {\r\n assert: defaultAssert,\r\n assertDeepEqual: defaultAssertDeepEqual,\r\n frameworkMatcher: false,\r\n run: true\r\n};\r\nfunction defaults() {\r\n return __assign({}, defaultConfiguration);\r\n}\r\nexports.defaults = defaults;\r\nfunction defaultAssert(value, message) {\r\n if (value) {\r\n return;\r\n }\r\n throw new Error(message);\r\n}\r\nfunction defaultAssertDeepEqual(a, b) {\r\n if (fast_equals_1.deepEqual(a, b)) {\r\n return;\r\n }\r\n throw new Error(\"Expected \" + toString(a) + \" to equal \" + toString(b) + \".\");\r\n}\r\nfunction toString(value) {\r\n if (value === null) {\r\n return \"null\";\r\n }\r\n else if (value === undefined) {\r\n return \"undefined\";\r\n }\r\n return value.toString();\r\n}\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/configuration.ts?");
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar fast_equals_1 = __webpack_require__(/*! fast-equals */ \"./node_modules/fast-equals/dist/fast-equals.js\");\r\nvar defaultConfiguration = {\r\n assert: defaultAssert,\r\n assertDeepEqual: defaultAssertDeepEqual,\r\n frameworkMatcher: false,\r\n run: true\r\n};\r\nfunction defaults() {\r\n return __assign({}, defaultConfiguration);\r\n}\r\nexports.defaults = defaults;\r\nfunction defaultAssert(value, message) {\r\n if (value) {\r\n return;\r\n }\r\n throw new Error(message);\r\n}\r\nfunction defaultAssertDeepEqual(a, b) {\r\n if (fast_equals_1.circularDeepEqual(a, b)) {\r\n return;\r\n }\r\n throw new Error(\"Expected \" + toString(a) + \" to equal \" + toString(b) + \".\");\r\n}\r\nfunction toString(value) {\r\n if (value === null) {\r\n return \"null\";\r\n }\r\n else if (value === undefined) {\r\n return \"undefined\";\r\n }\r\n return value.toString();\r\n}\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/configuration.ts?");

@@ -155,3 +155,3 @@ /***/ }),

"use strict";
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar rxjs_1 = __webpack_require__(/*! rxjs */ \"rxjs\");\r\nvar testing_1 = __webpack_require__(/*! rxjs/testing */ \"rxjs/testing\");\r\nvar args_1 = __webpack_require__(/*! ./args */ \"./source/args.ts\");\r\nvar assert_1 = __webpack_require__(/*! ./assert */ \"./source/assert.ts\");\r\nvar expect_1 = __webpack_require__(/*! ./expect */ \"./source/expect.ts\");\r\nvar matcher_1 = __webpack_require__(/*! ./matcher */ \"./source/matcher.ts\");\r\nvar DeprecatedContext = (function () {\r\n function DeprecatedContext(configuration_) {\r\n this.configuration_ = configuration_;\r\n this.autoFlush = true;\r\n this.bindings_ = [];\r\n this.frameTimeFactor_ = undefined;\r\n this.reframable_ = true;\r\n }\r\n Object.defineProperty(DeprecatedContext.prototype, \"scheduler\", {\r\n get: function () {\r\n var _this = this;\r\n if (!this.scheduler_) {\r\n this.scheduler_ = new testing_1.TestScheduler(function (a, b) {\r\n return matcher_1.observableMatcher(a, b, _this.configuration_.assert, _this.configuration_.assertDeepEqual, _this.configuration_.frameworkMatcher);\r\n });\r\n }\r\n return this.scheduler_;\r\n },\r\n enumerable: true,\r\n configurable: true\r\n });\r\n DeprecatedContext.prototype.bind = function () {\r\n var _this = this;\r\n var schedulers = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n schedulers[_i] = arguments[_i];\r\n }\r\n if (this.bindings_.length !== 0) {\r\n throw new Error(\"Schedulers already bound.\");\r\n }\r\n if (schedulers.length === 0) {\r\n schedulers = [\r\n rxjs_1.animationFrameScheduler,\r\n rxjs_1.asapScheduler,\r\n rxjs_1.asyncScheduler,\r\n rxjs_1.queueScheduler\r\n ];\r\n }\r\n this.bindings_ = schedulers.map(function (instance) {\r\n var now = instance.hasOwnProperty(\"now\") ? instance.now : undefined;\r\n instance.now = function () { return _this.scheduler.now(); };\r\n var schedule = instance.hasOwnProperty(\"schedule\")\r\n ? instance.schedule\r\n : undefined;\r\n instance.schedule = function (work, delay, state) {\r\n return _this.scheduler.schedule(work, delay, state);\r\n };\r\n return { instance: instance, now: now, schedule: schedule };\r\n });\r\n };\r\n DeprecatedContext.prototype.cold = function (marbles, values, error) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n var observable = scheduler.createColdObservable(marbles, values, error);\r\n observable[args_1.argsSymbol] = { error: error, marbles: marbles, values: values };\r\n return observable;\r\n };\r\n DeprecatedContext.prototype.configure = function (configuration) {\r\n if (this.scheduler_) {\r\n throw new Error(\"Scheduler already created; call configure before using other context methods and properties.\");\r\n }\r\n this.configuration_ = __assign({}, this.configuration_, configuration);\r\n };\r\n DeprecatedContext.prototype.equal = function (actual) {\r\n var args = [];\r\n for (var _i = 1; _i < arguments.length; _i++) {\r\n args[_i - 1] = arguments[_i];\r\n }\r\n var scheduler = this.scheduler;\r\n var a0 = args[0], a1 = args[1], a2 = args[2], a3 = args[3];\r\n if (a1 && typeof a1 === \"string\") {\r\n scheduler.expectObservable(actual, a0).toBe(a1, a2, a3);\r\n }\r\n else if (a1 && a1[args_1.argsSymbol]) {\r\n assert_1.assertArgs(a1);\r\n var _a = a1[args_1.argsSymbol], error = _a.error, marbles = _a.marbles, values = _a.values;\r\n scheduler.expectObservable(actual, a0).toBe(marbles, values, error);\r\n }\r\n else if (typeof a0 === \"string\") {\r\n scheduler.expectObservable(actual).toBe(a0, a1, a2);\r\n }\r\n else {\r\n assert_1.assertArgs(a0);\r\n var _b = a0[args_1.argsSymbol], error = _b.error, marbles = _b.marbles, values = _b.values;\r\n scheduler.expectObservable(actual).toBe(marbles, values, error);\r\n }\r\n };\r\n DeprecatedContext.prototype.expect = function (actual, subscription) {\r\n var scheduler = this.scheduler;\r\n return new expect_1.Expect(actual, scheduler, subscription);\r\n };\r\n DeprecatedContext.prototype.flush = function () {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n scheduler.flush();\r\n };\r\n DeprecatedContext.prototype.has = function (actual, expected) {\r\n assert_1.assertSubscriptions(actual);\r\n var scheduler = this.scheduler;\r\n scheduler.expectSubscriptions(actual.subscriptions).toBe(expected);\r\n };\r\n DeprecatedContext.prototype.hot = function (marbles, values, error) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n var observable = scheduler.createHotObservable(marbles, values, error);\r\n observable[args_1.argsSymbol] = { error: error, marbles: marbles, values: values };\r\n return observable;\r\n };\r\n DeprecatedContext.prototype.reframe = function (timePerFrame, maxTime) {\r\n if (!this.reframable_) {\r\n throw new Error(\"Cannot reframe; scheduler already used.\");\r\n }\r\n if (maxTime === undefined) {\r\n maxTime = timePerFrame * 75;\r\n }\r\n this.frameTimeFactor_ =\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor ||\r\n testing_1.TestScheduler.frameTimeFactor;\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor = timePerFrame;\r\n testing_1.TestScheduler.frameTimeFactor = timePerFrame;\r\n var scheduler = this.scheduler;\r\n scheduler.maxFrames = maxTime;\r\n };\r\n DeprecatedContext.prototype.teardown = function () {\r\n try {\r\n if (this.autoFlush) {\r\n this.scheduler.flush();\r\n }\r\n }\r\n finally {\r\n this.bindings_.forEach(function (_a) {\r\n var instance = _a.instance, now = _a.now, schedule = _a.schedule;\r\n if (now) {\r\n instance.now = now;\r\n }\r\n else {\r\n delete instance.now;\r\n }\r\n if (schedule) {\r\n instance.schedule = schedule;\r\n }\r\n else {\r\n delete instance.schedule;\r\n }\r\n });\r\n if (this.frameTimeFactor_) {\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor = this.frameTimeFactor_;\r\n testing_1.TestScheduler.frameTimeFactor = this.frameTimeFactor_;\r\n }\r\n }\r\n };\r\n DeprecatedContext.prototype.time = function (marbles) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n return scheduler.createTime(marbles);\r\n };\r\n return DeprecatedContext;\r\n}());\r\nexports.DeprecatedContext = DeprecatedContext;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/context-deprecated.ts?");
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar rxjs_1 = __webpack_require__(/*! rxjs */ \"rxjs\");\r\nvar testing_1 = __webpack_require__(/*! rxjs/testing */ \"rxjs/testing\");\r\nvar args_1 = __webpack_require__(/*! ./args */ \"./source/args.ts\");\r\nvar assert_1 = __webpack_require__(/*! ./assert */ \"./source/assert.ts\");\r\nvar expect_1 = __webpack_require__(/*! ./expect */ \"./source/expect.ts\");\r\nvar matcher_1 = __webpack_require__(/*! ./matcher */ \"./source/matcher.ts\");\r\nvar DeprecatedContext = (function () {\r\n function DeprecatedContext(configuration_) {\r\n this.configuration_ = configuration_;\r\n this.autoFlush = true;\r\n this.bindings_ = [];\r\n this.frameTimeFactor_ = undefined;\r\n this.reframable_ = true;\r\n }\r\n Object.defineProperty(DeprecatedContext.prototype, \"scheduler\", {\r\n get: function () {\r\n var _this = this;\r\n if (!this.scheduler_) {\r\n this.scheduler_ = new testing_1.TestScheduler(function (actual, expected) {\r\n return matcher_1.observableMatcher(actual, expected, _this.configuration_.assert, _this.configuration_.assertDeepEqual, _this.configuration_.frameworkMatcher);\r\n });\r\n }\r\n return this.scheduler_;\r\n },\r\n enumerable: true,\r\n configurable: true\r\n });\r\n DeprecatedContext.prototype.bind = function () {\r\n var _this = this;\r\n var schedulers = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n schedulers[_i] = arguments[_i];\r\n }\r\n if (this.bindings_.length !== 0) {\r\n throw new Error(\"Schedulers already bound.\");\r\n }\r\n if (schedulers.length === 0) {\r\n schedulers = [\r\n rxjs_1.animationFrameScheduler,\r\n rxjs_1.asapScheduler,\r\n rxjs_1.asyncScheduler,\r\n rxjs_1.queueScheduler\r\n ];\r\n }\r\n this.bindings_ = schedulers.map(function (instance) {\r\n var now = instance.hasOwnProperty(\"now\") ? instance.now : undefined;\r\n instance.now = function () { return _this.scheduler.now(); };\r\n var schedule = instance.hasOwnProperty(\"schedule\")\r\n ? instance.schedule\r\n : undefined;\r\n instance.schedule = function (work, delay, state) {\r\n return _this.scheduler.schedule(work, delay, state);\r\n };\r\n return { instance: instance, now: now, schedule: schedule };\r\n });\r\n };\r\n DeprecatedContext.prototype.cold = function (marbles, values, error) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n var observable = scheduler.createColdObservable(marbles, values, error);\r\n observable[args_1.argsSymbol] = { error: error, marbles: marbles, values: values };\r\n return observable;\r\n };\r\n DeprecatedContext.prototype.configure = function (configuration) {\r\n if (this.scheduler_) {\r\n throw new Error(\"Scheduler already created; call configure before using other context methods and properties.\");\r\n }\r\n this.configuration_ = __assign({}, this.configuration_, configuration);\r\n };\r\n DeprecatedContext.prototype.equal = function (actual) {\r\n var args = [];\r\n for (var _i = 1; _i < arguments.length; _i++) {\r\n args[_i - 1] = arguments[_i];\r\n }\r\n var scheduler = this.scheduler;\r\n var a0 = args[0], a1 = args[1], a2 = args[2], a3 = args[3];\r\n if (a1 && typeof a1 === \"string\") {\r\n scheduler.expectObservable(actual, a0).toBe(a1, a2, a3);\r\n }\r\n else if (a1 && a1[args_1.argsSymbol]) {\r\n assert_1.assertArgs(a1);\r\n var _a = a1[args_1.argsSymbol], error = _a.error, marbles = _a.marbles, values = _a.values;\r\n scheduler.expectObservable(actual, a0).toBe(marbles, values, error);\r\n }\r\n else if (typeof a0 === \"string\") {\r\n scheduler.expectObservable(actual).toBe(a0, a1, a2);\r\n }\r\n else {\r\n assert_1.assertArgs(a0);\r\n var _b = a0[args_1.argsSymbol], error = _b.error, marbles = _b.marbles, values = _b.values;\r\n scheduler.expectObservable(actual).toBe(marbles, values, error);\r\n }\r\n };\r\n DeprecatedContext.prototype.expect = function (actual, subscription) {\r\n var scheduler = this.scheduler;\r\n return new expect_1.Expect(actual, scheduler, subscription);\r\n };\r\n DeprecatedContext.prototype.flush = function () {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n scheduler.flush();\r\n };\r\n DeprecatedContext.prototype.has = function (actual, expected) {\r\n assert_1.assertSubscriptions(actual);\r\n var scheduler = this.scheduler;\r\n scheduler.expectSubscriptions(actual.subscriptions).toBe(expected);\r\n };\r\n DeprecatedContext.prototype.hot = function (marbles, values, error) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n var observable = scheduler.createHotObservable(marbles, values, error);\r\n observable[args_1.argsSymbol] = { error: error, marbles: marbles, values: values };\r\n return observable;\r\n };\r\n DeprecatedContext.prototype.reframe = function (timePerFrame, maxTime) {\r\n if (!this.reframable_) {\r\n throw new Error(\"Cannot reframe; scheduler already used.\");\r\n }\r\n if (maxTime === undefined) {\r\n maxTime = timePerFrame * 75;\r\n }\r\n this.frameTimeFactor_ =\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor ||\r\n testing_1.TestScheduler.frameTimeFactor;\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor = timePerFrame;\r\n testing_1.TestScheduler.frameTimeFactor = timePerFrame;\r\n var scheduler = this.scheduler;\r\n scheduler.maxFrames = maxTime;\r\n };\r\n DeprecatedContext.prototype.teardown = function () {\r\n try {\r\n if (this.autoFlush) {\r\n this.scheduler.flush();\r\n }\r\n }\r\n finally {\r\n this.bindings_.forEach(function (_a) {\r\n var instance = _a.instance, now = _a.now, schedule = _a.schedule;\r\n if (now) {\r\n instance.now = now;\r\n }\r\n else {\r\n delete instance.now;\r\n }\r\n if (schedule) {\r\n instance.schedule = schedule;\r\n }\r\n else {\r\n delete instance.schedule;\r\n }\r\n });\r\n if (this.frameTimeFactor_) {\r\n rxjs_1.VirtualTimeScheduler.frameTimeFactor = this.frameTimeFactor_;\r\n testing_1.TestScheduler.frameTimeFactor = this.frameTimeFactor_;\r\n }\r\n }\r\n };\r\n DeprecatedContext.prototype.time = function (marbles) {\r\n var scheduler = this.scheduler;\r\n this.reframable_ = false;\r\n return scheduler.createTime(marbles);\r\n };\r\n return DeprecatedContext;\r\n}());\r\nexports.DeprecatedContext = DeprecatedContext;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/context-deprecated.ts?");

@@ -204,3 +204,3 @@ /***/ }),

"use strict";
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar testing_1 = __webpack_require__(/*! rxjs/testing */ \"rxjs/testing\");\r\nvar configuration_1 = __webpack_require__(/*! ./configuration */ \"./source/configuration.ts\");\r\nvar context_deprecated_1 = __webpack_require__(/*! ./context-deprecated */ \"./source/context-deprecated.ts\");\r\nvar context_run_1 = __webpack_require__(/*! ./context-run */ \"./source/context-run.ts\");\r\nvar matcher_1 = __webpack_require__(/*! ./matcher */ \"./source/matcher.ts\");\r\nfunction configure(configurationOrFactory) {\r\n function deriveConfiguration() {\r\n var args = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n args[_i] = arguments[_i];\r\n }\r\n var explicit = typeof configurationOrFactory === \"function\"\r\n ? configurationOrFactory.apply(void 0, args) : configurationOrFactory;\r\n return __assign({}, configuration_1.defaults(), explicit);\r\n }\r\n function _marbles(func) {\r\n var wrapper = function () {\r\n var _this = this;\r\n var rest = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n rest[_i] = arguments[_i];\r\n }\r\n var configuration = deriveConfiguration.apply(void 0, rest);\r\n if (configuration.run) {\r\n var scheduler_1 = new testing_1.TestScheduler(function (a, b) {\r\n return matcher_1.observableMatcher(a, b, configuration.assert, configuration.assertDeepEqual, configuration.frameworkMatcher);\r\n });\r\n return scheduler_1.run(function (helpers) {\r\n return func.call.apply(func, [_this, new context_run_1.RunContext(scheduler_1, helpers)].concat(rest));\r\n });\r\n }\r\n var context = new context_deprecated_1.DeprecatedContext(configuration);\r\n try {\r\n return func.call.apply(func, [this, context].concat(rest));\r\n }\r\n finally {\r\n context.teardown();\r\n }\r\n };\r\n if (func.length > 1) {\r\n return function (first) {\r\n var rest = [];\r\n for (var _i = 1; _i < arguments.length; _i++) {\r\n rest[_i - 1] = arguments[_i];\r\n }\r\n return wrapper.apply(void 0, [first].concat(rest));\r\n };\r\n }\r\n return wrapper;\r\n }\r\n return { marbles: _marbles };\r\n}\r\nexports.configure = configure;\r\nexports.marbles = configure(configuration_1.defaults()).marbles;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/marbles.ts?");
eval("\r\nvar __assign = (this && this.__assign) || function () {\r\n __assign = Object.assign || function(t) {\r\n for (var s, i = 1, n = arguments.length; i < n; i++) {\r\n s = arguments[i];\r\n for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))\r\n t[p] = s[p];\r\n }\r\n return t;\r\n };\r\n return __assign.apply(this, arguments);\r\n};\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar testing_1 = __webpack_require__(/*! rxjs/testing */ \"rxjs/testing\");\r\nvar configuration_1 = __webpack_require__(/*! ./configuration */ \"./source/configuration.ts\");\r\nvar context_deprecated_1 = __webpack_require__(/*! ./context-deprecated */ \"./source/context-deprecated.ts\");\r\nvar context_run_1 = __webpack_require__(/*! ./context-run */ \"./source/context-run.ts\");\r\nvar matcher_1 = __webpack_require__(/*! ./matcher */ \"./source/matcher.ts\");\r\nfunction configure(configurationOrFactory) {\r\n function deriveConfiguration() {\r\n var args = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n args[_i] = arguments[_i];\r\n }\r\n var explicit = typeof configurationOrFactory === \"function\"\r\n ? configurationOrFactory.apply(void 0, args) : configurationOrFactory;\r\n return __assign({}, configuration_1.defaults(), explicit);\r\n }\r\n function _marbles(func) {\r\n var wrapper = function () {\r\n var _this = this;\r\n var rest = [];\r\n for (var _i = 0; _i < arguments.length; _i++) {\r\n rest[_i] = arguments[_i];\r\n }\r\n var configuration = deriveConfiguration.apply(void 0, rest);\r\n if (configuration.run) {\r\n var scheduler_1 = new testing_1.TestScheduler(function (actual, expected) {\r\n return matcher_1.observableMatcher(actual, expected, configuration.assert, configuration.assertDeepEqual, configuration.frameworkMatcher);\r\n });\r\n return scheduler_1.run(function (helpers) {\r\n return func.call.apply(func, [_this, new context_run_1.RunContext(scheduler_1, helpers)].concat(rest));\r\n });\r\n }\r\n var context = new context_deprecated_1.DeprecatedContext(configuration);\r\n try {\r\n return func.call.apply(func, [this, context].concat(rest));\r\n }\r\n finally {\r\n context.teardown();\r\n }\r\n };\r\n if (func.length > 1) {\r\n return function (first) {\r\n var rest = [];\r\n for (var _i = 1; _i < arguments.length; _i++) {\r\n rest[_i - 1] = arguments[_i];\r\n }\r\n return wrapper.apply(void 0, [first].concat(rest));\r\n };\r\n }\r\n return wrapper;\r\n }\r\n return { marbles: _marbles };\r\n}\r\nexports.configure = configure;\r\nexports.marbles = configure(configuration_1.defaults()).marbles;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/marbles.ts?");

@@ -217,3 +217,3 @@ /***/ }),

"use strict";
eval("\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar fast_equals_1 = __webpack_require__(/*! fast-equals */ \"./node_modules/fast-equals/dist/fast-equals.js\");\r\nfunction stringify(x) {\r\n if (x === undefined) {\r\n return \"undefined\";\r\n }\r\n return JSON.stringify(x, function (key, value) {\r\n if (Array.isArray(value)) {\r\n return (\"[\" +\r\n value.map(function (i) {\r\n return \"\\n\\t\" + stringify(i);\r\n }) +\r\n \"\\n]\");\r\n }\r\n return value;\r\n })\r\n .replace(/\\\\\"/g, '\"')\r\n .replace(/\\\\t/g, \"\\t\")\r\n .replace(/\\\\n/g, \"\\n\");\r\n}\r\nfunction deleteErrorNotificationStack(marble) {\r\n var notification = marble.notification;\r\n if (notification) {\r\n var kind = notification.kind, error = notification.error;\r\n if (kind === \"E\" && error instanceof Error) {\r\n notification.error = { name: error.name, message: error.message };\r\n }\r\n }\r\n return marble;\r\n}\r\nfunction observableMatcher(actual, expected, assert, assertDeepEqual, frameworkMatcher) {\r\n if (Array.isArray(actual) && Array.isArray(expected)) {\r\n actual = actual.map(deleteErrorNotificationStack);\r\n expected = expected.map(deleteErrorNotificationStack);\r\n if (frameworkMatcher) {\r\n assertDeepEqual(actual, expected);\r\n }\r\n else {\r\n var passed = fast_equals_1.deepEqual(actual, expected);\r\n if (passed) {\r\n assert(true, \"\");\r\n return;\r\n }\r\n var message_1 = \"\\nExpected \\n\";\r\n actual.forEach(function (x) { return (message_1 += \"\\t\" + stringify(x) + \"\\n\"); });\r\n message_1 += \"\\t\\nto deep equal \\n\";\r\n expected.forEach(function (x) { return (message_1 += \"\\t\" + stringify(x) + \"\\n\"); });\r\n assert(passed, message_1);\r\n }\r\n }\r\n else {\r\n assertDeepEqual(actual, expected);\r\n }\r\n}\r\nexports.observableMatcher = observableMatcher;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/matcher.ts?");
eval("\r\nObject.defineProperty(exports, \"__esModule\", { value: true });\r\nvar fast_equals_1 = __webpack_require__(/*! fast-equals */ \"./node_modules/fast-equals/dist/fast-equals.js\");\r\nfunction stringify(x) {\r\n if (x === undefined) {\r\n return \"undefined\";\r\n }\r\n return JSON.stringify(x, function (key, value) {\r\n if (Array.isArray(value)) {\r\n return (\"[\" +\r\n value.map(function (i) {\r\n return \"\\n\\t\" + stringify(i);\r\n }) +\r\n \"\\n]\");\r\n }\r\n return value;\r\n })\r\n .replace(/\\\\\"/g, '\"')\r\n .replace(/\\\\t/g, \"\\t\")\r\n .replace(/\\\\n/g, \"\\n\");\r\n}\r\nfunction deleteErrorNotificationStack(marble) {\r\n var notification = marble.notification;\r\n if (notification) {\r\n var kind = notification.kind, error = notification.error;\r\n if (kind === \"E\" && error instanceof Error) {\r\n notification.error = { name: error.name, message: error.message };\r\n }\r\n }\r\n return marble;\r\n}\r\nfunction observableMatcher(actual, expected, assert, assertDeepEqual, frameworkMatcher) {\r\n if (Array.isArray(actual) && Array.isArray(expected)) {\r\n actual = actual.map(deleteErrorNotificationStack);\r\n expected = expected.map(deleteErrorNotificationStack);\r\n if (frameworkMatcher) {\r\n assertDeepEqual(actual, expected);\r\n }\r\n else {\r\n var passed = fast_equals_1.circularDeepEqual(actual, expected);\r\n if (passed) {\r\n assert(true, \"\");\r\n return;\r\n }\r\n var message_1 = \"\\nExpected \\n\";\r\n actual.forEach(function (x) { return (message_1 += \"\\t\" + stringify(x) + \"\\n\"); });\r\n message_1 += \"\\t\\nto deep equal \\n\";\r\n expected.forEach(function (x) { return (message_1 += \"\\t\" + stringify(x) + \"\\n\"); });\r\n assert(passed, message_1);\r\n }\r\n }\r\n else {\r\n assertDeepEqual(actual, expected);\r\n }\r\n}\r\nexports.observableMatcher = observableMatcher;\r\n\n\n//# sourceURL=webpack://rxjsMarbles/./source/matcher.ts?");

@@ -220,0 +220,0 @@ /***/ }),

7

CHANGELOG.md

@@ -0,1 +1,8 @@

<a name="5.0.2"></a>
## [5.0.2](https://github.com/cartant/rxjs-marbles/compare/v5.0.1...v5.0.2) (2019-04-23)
### Fixes
* Call `circularDeepEqual` instead of `deepEqual` so that higher-order observables are asserted correctly. ([cdb43eb](https://github.com/cartant/rxjs-marbles/commit/cdb43eb))
<a name="5.0.1"></a>

@@ -2,0 +9,0 @@ ## [5.0.1](https://github.com/cartant/rxjs-marbles/compare/v5.0.0...v5.0.1) (2019-04-01)

2

configuration.js

@@ -32,3 +32,3 @@ "use strict";

function defaultAssertDeepEqual(a, b) {
if (fast_equals_1.deepEqual(a, b)) {
if (fast_equals_1.circularDeepEqual(a, b)) {
return;

@@ -35,0 +35,0 @@ }

4

context-deprecated.js

@@ -32,4 +32,4 @@ "use strict";

if (!this.scheduler_) {
this.scheduler_ = new testing_1.TestScheduler(function (a, b) {
return matcher_1.observableMatcher(a, b, _this.configuration_.assert, _this.configuration_.assertDeepEqual, _this.configuration_.frameworkMatcher);
this.scheduler_ = new testing_1.TestScheduler(function (actual, expected) {
return matcher_1.observableMatcher(actual, expected, _this.configuration_.assert, _this.configuration_.assertDeepEqual, _this.configuration_.frameworkMatcher);
});

@@ -36,0 +36,0 @@ }

4

esm2015/configuration.js

@@ -1,2 +0,2 @@

import { deepEqual } from "fast-equals";
import { circularDeepEqual } from "fast-equals";
const defaultConfiguration = {

@@ -18,3 +18,3 @@ assert: defaultAssert,

function defaultAssertDeepEqual(a, b) {
if (deepEqual(a, b)) {
if (circularDeepEqual(a, b)) {
return;

@@ -21,0 +21,0 @@ }

2

esm2015/context-deprecated.js

@@ -17,3 +17,3 @@ import { animationFrameScheduler, asapScheduler, asyncScheduler, queueScheduler, VirtualTimeScheduler } from "rxjs";

if (!this.scheduler_) {
this.scheduler_ = new TestScheduler((a, b) => observableMatcher(a, b, this.configuration_.assert, this.configuration_.assertDeepEqual, this.configuration_.frameworkMatcher));
this.scheduler_ = new TestScheduler((actual, expected) => observableMatcher(actual, expected, this.configuration_.assert, this.configuration_.assertDeepEqual, this.configuration_.frameworkMatcher));
}

@@ -20,0 +20,0 @@ return this.scheduler_;

2

esm2015/marbles.js

@@ -17,3 +17,3 @@ import { TestScheduler } from "rxjs/testing";

if (configuration.run) {
const scheduler = new TestScheduler((a, b) => observableMatcher(a, b, configuration.assert, configuration.assertDeepEqual, configuration.frameworkMatcher));
const scheduler = new TestScheduler((actual, expected) => observableMatcher(actual, expected, configuration.assert, configuration.assertDeepEqual, configuration.frameworkMatcher));
return scheduler.run(helpers => func.call(this, new RunContext(scheduler, helpers), ...rest));

@@ -20,0 +20,0 @@ }

4

esm2015/matcher.js

@@ -1,2 +0,2 @@

import { deepEqual } from "fast-equals";
import { circularDeepEqual } from "fast-equals";
function stringify(x) {

@@ -38,3 +38,3 @@ if (x === undefined) {

else {
const passed = deepEqual(actual, expected);
const passed = circularDeepEqual(actual, expected);
if (passed) {

@@ -41,0 +41,0 @@ assert(true, "");

4

esm5/configuration.js

@@ -12,3 +12,3 @@ var __assign = (this && this.__assign) || function () {

};
import { deepEqual } from "fast-equals";
import { circularDeepEqual } from "fast-equals";
var defaultConfiguration = {

@@ -30,3 +30,3 @@ assert: defaultAssert,

function defaultAssertDeepEqual(a, b) {
if (deepEqual(a, b)) {
if (circularDeepEqual(a, b)) {
return;

@@ -33,0 +33,0 @@ }

4

esm5/context-deprecated.js

@@ -30,4 +30,4 @@ var __assign = (this && this.__assign) || function () {

if (!this.scheduler_) {
this.scheduler_ = new TestScheduler(function (a, b) {
return observableMatcher(a, b, _this.configuration_.assert, _this.configuration_.assertDeepEqual, _this.configuration_.frameworkMatcher);
this.scheduler_ = new TestScheduler(function (actual, expected) {
return observableMatcher(actual, expected, _this.configuration_.assert, _this.configuration_.assertDeepEqual, _this.configuration_.frameworkMatcher);
});

@@ -34,0 +34,0 @@ }

4

esm5/marbles.js

@@ -36,4 +36,4 @@ var __assign = (this && this.__assign) || function () {

if (configuration.run) {
var scheduler_1 = new TestScheduler(function (a, b) {
return observableMatcher(a, b, configuration.assert, configuration.assertDeepEqual, configuration.frameworkMatcher);
var scheduler_1 = new TestScheduler(function (actual, expected) {
return observableMatcher(actual, expected, configuration.assert, configuration.assertDeepEqual, configuration.frameworkMatcher);
});

@@ -40,0 +40,0 @@ return scheduler_1.run(function (helpers) {

4

esm5/matcher.js

@@ -1,2 +0,2 @@

import { deepEqual } from "fast-equals";
import { circularDeepEqual } from "fast-equals";
function stringify(x) {

@@ -38,3 +38,3 @@ if (x === undefined) {

else {
var passed = deepEqual(actual, expected);
var passed = circularDeepEqual(actual, expected);
if (passed) {

@@ -41,0 +41,0 @@ assert(true, "");

4

marbles.js

@@ -38,4 +38,4 @@ "use strict";

if (configuration.run) {
var scheduler_1 = new testing_1.TestScheduler(function (a, b) {
return matcher_1.observableMatcher(a, b, configuration.assert, configuration.assertDeepEqual, configuration.frameworkMatcher);
var scheduler_1 = new testing_1.TestScheduler(function (actual, expected) {
return matcher_1.observableMatcher(actual, expected, configuration.assert, configuration.assertDeepEqual, configuration.frameworkMatcher);
});

@@ -42,0 +42,0 @@ return scheduler_1.run(function (helpers) {

2

matcher.js

@@ -40,3 +40,3 @@ "use strict";

else {
var passed = fast_equals_1.deepEqual(actual, expected);
var passed = fast_equals_1.circularDeepEqual(actual, expected);
if (passed) {

@@ -43,0 +43,0 @@ assert(true, "");

2

package.json

@@ -51,4 +51,4 @@ {

"unpkg": "./bundles/rxjs-marbles.umd.js",
"version": "5.0.1",
"version": "5.0.2",
"ava": {}
}
SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

About

Packages

npm

Go

Maven

PyPI

Rubygems

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc