Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More
Socket
Sign inDemoInstall
Socket

rxjs-marbles

Package Overview
Dependencies
Maintainers
1
Versions
53
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

rxjs-marbles - npm Package Compare versions

Comparing version 2.3.3 to 3.0.0-rc.0

esm2015/args.js

4

args.js

@@ -1,1 +0,3 @@

export var argsSymbol = Symbol("args");
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.argsSymbol = Symbol("args");

@@ -1,3 +0,3 @@

import { Observable } from "rxjs/Observable";
import { Observable } from "rxjs";
export declare function assertArgs<T>(observable: Observable<T>): void;
export declare function assertSubscriptions<T>(observable: Observable<T>): void;

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

import { argsSymbol } from "./args";
export function assertArgs(observable) {
if (!observable[argsSymbol]) {
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
var args_1 = require("./args");
function assertArgs(observable) {
if (!observable[args_1.argsSymbol]) {
throw new Error("Expected a hot or cold test observable.");
}
}
export function assertSubscriptions(observable) {
exports.assertArgs = assertArgs;
function assertSubscriptions(observable) {
if (!observable["subscriptions"]) {

@@ -12,1 +15,2 @@ throw new Error("Expected a hot or cold test observable with subscriptions.");

}
exports.assertSubscriptions = assertSubscriptions;

@@ -1,15 +0,22 @@

import { test } from "ava";
import { _cases } from "../cases";
import { marbles as _marbles } from "../marbles";
export { configure } from "../configuration";
export * from "../context";
export * from "../expect";
export function cases(name, func, cases) {
_cases(function (c) {
var t = c.only ? test.only : c.skip ? test.skip : test;
"use strict";
function __export(m) {
for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
}
Object.defineProperty(exports, "__esModule", { value: true });
var ava_1 = require("ava");
var cases_1 = require("../cases");
var marbles_1 = require("../marbles");
var configuration_1 = require("../configuration");
exports.configure = configuration_1.configure;
__export(require("../context"));
__export(require("../expect"));
function cases(name, func, cases) {
cases_1._cases(function (c) {
var t = c.only ? ava_1.test.only : c.skip ? ava_1.test.skip : ava_1.test;
t(name + " / " + c.name, marbles(function (m, t) { return func(m, c, t); }));
}, cases);
}
export function marbles(func) {
return _marbles(function (m, t) {
exports.cases = cases;
function marbles(func) {
return marbles_1.marbles(function (m, t) {
m.configure({

@@ -22,1 +29,2 @@ assert: t.truthy.bind(t),

}
exports.marbles = marbles;
{
"main": "../bundles/rxjs-marbles-ava.umd.js",
"module": "./index.js",
"typings": "./index.d.ts"
"es2015": "../esm2015/ava/index.js",
"main": "./index.js",
"module": "../esm5/ava/index.js",
"typings": "../index.d.ts"
}

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

"use strict";
var __assign = (this && this.__assign) || Object.assign || function(t) {

@@ -9,4 +10,5 @@ for (var s, i = 1, n = arguments.length; i < n; i++) {

};
import isArray from "lodash-es/isArray";
export function _cases(adapter, cases) {
Object.defineProperty(exports, "__esModule", { value: true });
var isArray = require("lodash/isArray");
function _cases(adapter, cases) {
if (!isArray(cases)) {

@@ -17,1 +19,2 @@ cases = Object.keys(cases).map(function (key) { return (__assign({}, cases[key], { name: key })); });

}
exports._cases = _cases;

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

"use strict";
var __assign = (this && this.__assign) || Object.assign || function(t) {

@@ -9,3 +10,4 @@ for (var s, i = 1, n = arguments.length; i < n; i++) {

};
import isEqual from "lodash-es/isEqual";
Object.defineProperty(exports, "__esModule", { value: true });
var isEqual = require("lodash/isEqual");
var configuration = {

@@ -16,8 +18,10 @@ assert: defaultAssert,

};
export function configure(options) {
function configure(options) {
configuration = __assign({}, options);
}
export function get(key) {
exports.configure = configure;
function get(key) {
return configuration[key];
}
exports.get = get;
function defaultAssert(value, message) {

@@ -24,0 +28,0 @@ if (value) {

@@ -1,6 +0,5 @@

import { Observable } from "rxjs/Observable";
import { IScheduler } from "rxjs/Scheduler";
import { ColdObservable } from "rxjs/testing/ColdObservable";
import { HotObservable } from "rxjs/testing/HotObservable";
import { TestScheduler } from "rxjs/testing/TestScheduler";
import { Observable, SchedulerLike } from "rxjs";
import { TestScheduler } from "rxjs/testing";
import { ColdObservable } from "rxjs/internal/testing/ColdObservable";
import { HotObservable } from "rxjs/internal/testing/HotObservable";
import { configure } from "./configuration";

@@ -14,3 +13,3 @@ import { Expect } from "./expect";

constructor(scheduler: TestScheduler);
bind(...schedulers: IScheduler[]): void;
bind(...schedulers: SchedulerLike[]): void;
cold<T = any>(marbles: string, values?: {

@@ -17,0 +16,0 @@ [key: string]: T;

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

import { animationFrame } from "rxjs/scheduler/animationFrame";
import { asap } from "rxjs/scheduler/asap";
import { async } from "rxjs/scheduler/async";
import { queue } from "rxjs/scheduler/queue";
import { argsSymbol } from "./args";
import { assertArgs, assertSubscriptions } from "./assert";
import { configure } from "./configuration";
import { Expect } from "./expect";
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
var rxjs_1 = require("rxjs");
var args_1 = require("./args");
var assert_1 = require("./assert");
var configuration_1 = require("./configuration");
var expect_1 = require("./expect");
var Context = (function () {

@@ -13,3 +12,3 @@ function Context(scheduler) {

this.autoFlush = true;
this.configure = configure;
this.configure = configuration_1.configure;
this.bindings_ = [];

@@ -27,3 +26,8 @@ }

if (schedulers.length === 0) {
schedulers = [animationFrame, asap, async, queue];
schedulers = [
rxjs_1.animationFrameScheduler,
rxjs_1.asapScheduler,
rxjs_1.asyncScheduler,
rxjs_1.queueScheduler
];
}

@@ -41,3 +45,3 @@ this.bindings_ = schedulers.map(function (instance) {

var observable = scheduler.createColdObservable(marbles, values, error);
observable[argsSymbol] = { error: error, marbles: marbles, values: values };
observable[args_1.argsSymbol] = { error: error, marbles: marbles, values: values };
return observable;

@@ -55,5 +59,5 @@ };

}
else if (a1 && a1[argsSymbol]) {
assertArgs(a1);
var _a = a1[argsSymbol], error = _a.error, marbles = _a.marbles, values = _a.values;
else if (a1 && a1[args_1.argsSymbol]) {
assert_1.assertArgs(a1);
var _a = a1[args_1.argsSymbol], error = _a.error, marbles = _a.marbles, values = _a.values;
scheduler.expectObservable(actual, a0).toBe(marbles, values, error);

@@ -65,4 +69,4 @@ }

else {
assertArgs(a0);
var _b = a0[argsSymbol], error = _b.error, marbles = _b.marbles, values = _b.values;
assert_1.assertArgs(a0);
var _b = a0[args_1.argsSymbol], error = _b.error, marbles = _b.marbles, values = _b.values;
scheduler.expectObservable(actual).toBe(marbles, values, error);

@@ -73,3 +77,3 @@ }

var scheduler = this.scheduler;
return new Expect(actual, scheduler, unsubscription);
return new expect_1.Expect(actual, scheduler, unsubscription);
};

@@ -81,3 +85,3 @@ Context.prototype.flush = function () {

Context.prototype.has = function (actual, expected) {
assertSubscriptions(actual);
assert_1.assertSubscriptions(actual);
var scheduler = this.scheduler;

@@ -89,3 +93,3 @@ scheduler.expectSubscriptions(actual.subscriptions).toBe(expected);

var observable = scheduler.createHotObservable(marbles, values, error);
observable[argsSymbol] = { error: error, marbles: marbles, values: values };
observable[args_1.argsSymbol] = { error: error, marbles: marbles, values: values };
return observable;

@@ -123,2 +127,2 @@ };

}());
export { Context };
exports.Context = Context;

@@ -1,4 +0,4 @@

import { ColdObservable } from "rxjs/testing/ColdObservable";
import { HotObservable } from "rxjs/testing/HotObservable";
import { TestScheduler } from "rxjs/testing/TestScheduler";
import { TestScheduler } from "rxjs/testing";
import { ColdObservable } from "rxjs/internal/testing/ColdObservable";
import { HotObservable } from "rxjs/internal/testing/HotObservable";
export declare class Expect<T> {

@@ -5,0 +5,0 @@ private actual;

@@ -1,3 +0,5 @@

import { argsSymbol } from "./args";
import { assertArgs, assertSubscriptions } from "./assert";
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
var args_1 = require("./args");
var assert_1 = require("./assert");
var Expect = (function () {

@@ -15,4 +17,4 @@ function Expect(actual, scheduler, unsubscription) {

else {
assertArgs(expected);
var _b = expected[argsSymbol], error_1 = _b.error, marbles = _b.marbles, values_1 = _b.values;
assert_1.assertArgs(expected);
var _b = expected[args_1.argsSymbol], error_1 = _b.error, marbles = _b.marbles, values_1 = _b.values;
scheduler.expectObservable(actual, unsubscription).toBe(marbles, values_1, error_1);

@@ -23,3 +25,3 @@ }

var _a = this, actual = _a.actual, scheduler = _a.scheduler;
assertSubscriptions(actual);
assert_1.assertSubscriptions(actual);
scheduler.expectSubscriptions(actual.subscriptions).toBe(expected);

@@ -29,2 +31,2 @@ };

}());
export { Expect };
exports.Expect = Expect;

@@ -1,5 +0,11 @@

export { configure } from "./configuration";
export * from "./cases";
export * from "./context";
export * from "./expect";
export * from "./marbles";
"use strict";
function __export(m) {
for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
}
Object.defineProperty(exports, "__esModule", { value: true });
var configuration_1 = require("./configuration");
exports.configure = configuration_1.configure;
__export(require("./cases"));
__export(require("./context"));
__export(require("./expect"));
__export(require("./marbles"));

@@ -1,13 +0,19 @@

import { _cases } from "../cases";
import { marbles } from "../marbles";
export { configure } from "../configuration";
export * from "../context";
export * from "../expect";
export * from "../marbles";
export function cases(name, func, cases) {
"use strict";
function __export(m) {
for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
}
Object.defineProperty(exports, "__esModule", { value: true });
var cases_1 = require("../cases");
var marbles_1 = require("../marbles");
var configuration_1 = require("../configuration");
exports.configure = configuration_1.configure;
__export(require("../context"));
__export(require("../expect"));
__export(require("../marbles"));
function cases(name, func, cases) {
describe(name, function () {
_cases(function (c) {
cases_1._cases(function (c) {
var t = c.only ? fit : c.skip ? xit : it;
if (func.length > 2) {
t(c.name, marbles(function (m, second) {
t(c.name, marbles_1.marbles(function (m, second) {
var rest = [];

@@ -21,3 +27,3 @@ for (var _i = 2; _i < arguments.length; _i++) {

else {
t(c.name, marbles(function (m) {
t(c.name, marbles_1.marbles(function (m) {
var rest = [];

@@ -33,1 +39,2 @@ for (var _i = 1; _i < arguments.length; _i++) {

}
exports.cases = cases;
{
"main": "../bundles/rxjs-marbles-jasmine.umd.js",
"module": "./index.js",
"typings": "./index.d.ts"
"es2015": "../esm2015/jasmine/index.js",
"main": "./index.js",
"module": "../esm5/jasmine/index.js",
"typings": "../index.d.ts"
}

@@ -1,9 +0,15 @@

import { _cases } from "../cases";
import { marbles as _marbles } from "../marbles";
export { configure } from "../configuration";
export * from "../context";
export * from "../expect";
export function cases(name, func, cases) {
"use strict";
function __export(m) {
for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
}
Object.defineProperty(exports, "__esModule", { value: true });
var cases_1 = require("../cases");
var marbles_1 = require("../marbles");
var configuration_1 = require("../configuration");
exports.configure = configuration_1.configure;
__export(require("../context"));
__export(require("../expect"));
function cases(name, func, cases) {
describe(name, function () {
_cases(function (c) {
cases_1._cases(function (c) {
var t = c.only ? test.only : c.skip ? test.skip : test;

@@ -31,4 +37,5 @@ if (func.length > 2) {

}
export function marbles(func) {
return _marbles(function (m) {
exports.cases = cases;
function marbles(func) {
return marbles_1.marbles(function (m) {
var rest = [];

@@ -45,1 +52,2 @@ for (var _i = 1; _i < arguments.length; _i++) {

}
exports.marbles = marbles;
{
"main": "../bundles/rxjs-marbles-jest.umd.js",
"module": "./index.js",
"typings": "./index.d.ts"
"es2015": "../esm2015/jest/index.js",
"main": "./index.js",
"module": "../esm5/jest/index.js",
"typings": "../index.d.ts"
}

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

import { TestScheduler } from "rxjs/testing/TestScheduler";
import { get } from "./configuration";
import { Context } from "./context";
import { observableMatcher } from "./matcher";
export function marbles(func) {
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
var testing_1 = require("rxjs/testing");
var configuration_1 = require("./configuration");
var context_1 = require("./context");
var matcher_1 = require("./matcher");
function marbles(func) {
if (func.length > 1) {

@@ -12,7 +14,6 @@ return function (first) {

}
var scheduler = new TestScheduler(function (a, b) { return observableMatcher(a, b, get("assert"), get("assertDeepEqual"), get("frameworkMatcher")); });
var context = new Context(scheduler);
var scheduler = new testing_1.TestScheduler(function (a, b) { return matcher_1.observableMatcher(a, b, configuration_1.get("assert"), configuration_1.get("assertDeepEqual"), configuration_1.get("frameworkMatcher")); });
var context = new context_1.Context(scheduler);
try {
var result = func.apply(void 0, [context, first].concat(rest));
return result;
return func.apply(void 0, [context, first].concat(rest));
}

@@ -29,7 +30,6 @@ finally {

}
var scheduler = new TestScheduler(function (a, b) { return observableMatcher(a, b, get("assert"), get("assertDeepEqual"), get("frameworkMatcher")); });
var context = new Context(scheduler);
var scheduler = new testing_1.TestScheduler(function (a, b) { return matcher_1.observableMatcher(a, b, configuration_1.get("assert"), configuration_1.get("assertDeepEqual"), configuration_1.get("frameworkMatcher")); });
var context = new context_1.Context(scheduler);
try {
var result = func.apply(void 0, [context].concat(rest));
return result;
return func.apply(void 0, [context].concat(rest));
}

@@ -41,1 +41,2 @@ finally {

}
exports.marbles = marbles;

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

import isEqual from "lodash-es/isEqual";
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
var isEqual = require("lodash/isEqual");
function stringify(x) {

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

}
export function observableMatcher(actual, expected, assert, assertDeepEqual, frameworkMatcher) {
function observableMatcher(actual, expected, assert, assertDeepEqual, frameworkMatcher) {
if (Array.isArray(actual) && Array.isArray(expected)) {

@@ -54,1 +56,2 @@ actual = actual.map(deleteErrorNotificationStack);

}
exports.observableMatcher = observableMatcher;

@@ -1,13 +0,19 @@

import { _cases } from "../cases";
import { marbles } from "../marbles";
export { configure } from "../configuration";
export * from "../context";
export * from "../expect";
export * from "../marbles";
export function cases(name, func, cases) {
"use strict";
function __export(m) {
for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
}
Object.defineProperty(exports, "__esModule", { value: true });
var cases_1 = require("../cases");
var marbles_1 = require("../marbles");
var configuration_1 = require("../configuration");
exports.configure = configuration_1.configure;
__export(require("../context"));
__export(require("../expect"));
__export(require("../marbles"));
function cases(name, func, cases) {
describe(name, function () {
_cases(function (c) {
cases_1._cases(function (c) {
var t = c.only ? it.only : c.skip ? it.skip : it;
if (func.length > 2) {
t(c.name, marbles(function (m, second) {
t(c.name, marbles_1.marbles(function (m, second) {
var rest = [];

@@ -21,3 +27,3 @@ for (var _i = 2; _i < arguments.length; _i++) {

else {
t(c.name, marbles(function (m) {
t(c.name, marbles_1.marbles(function (m) {
var rest = [];

@@ -33,1 +39,2 @@ for (var _i = 1; _i < arguments.length; _i++) {

}
exports.cases = cases;
{
"main": "../bundles/rxjs-marbles-mocha.umd.js",
"module": "./index.js",
"typings": "./index.d.ts"
"es2015": "../esm2015/mocha/index.js",
"main": "./index.js",
"module": "../esm5/mocha/index.js",
"typings": "../index.d.ts"
}

@@ -7,10 +7,10 @@ {

"dependencies": {
"@types/lodash-es": "^4.0.0",
"lodash-es": "^4.0.0"
"@types/lodash": "^4.0.0",
"lodash": "^4.0.0"
},
"description": "An RxJS marble testing library for any test framework",
"devDependencies": {},
"es2015": "./esm2015/index.js",
"homepage": "https://github.com/cartant/rxjs-marbles",
"jest": {},
"jsnext:main": "./index.js",
"keywords": [

@@ -29,4 +29,4 @@ "ava",

"license": "MIT",
"main": "./bundles/rxjs-marbles.umd.js",
"module": "./index.js",
"main": "./index.js",
"module": "./esm5/index.js",
"name": "rxjs-marbles",

@@ -38,2 +38,5 @@ "optionalDependencies": {},

"private": false,
"publishConfig": {
"tag": "rc"
},
"repository": {

@@ -46,4 +49,4 @@ "type": "git",

"unpkg": "./bundles/rxjs-marbles.umd.js",
"version": "2.3.3",
"version": "3.0.0-rc.0",
"ava": {}
}

@@ -1,9 +0,15 @@

import * as tape from "tape";
import { _cases } from "../cases";
import { marbles as _marbles } from "../marbles";
export { configure } from "../configuration";
export * from "../context";
export * from "../expect";
export function cases(name, func, cases) {
_cases(function (c) {
"use strict";
function __export(m) {
for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
}
Object.defineProperty(exports, "__esModule", { value: true });
var tape = require("tape");
var cases_1 = require("../cases");
var marbles_1 = require("../marbles");
var configuration_1 = require("../configuration");
exports.configure = configuration_1.configure;
__export(require("../context"));
__export(require("../expect"));
function cases(name, func, cases) {
cases_1._cases(function (c) {
var t = c.only ? tape.only : c.skip ? tape.skip : tape;

@@ -13,4 +19,5 @@ t(name + " / " + c.name, marbles(function (m, t) { return func(m, c, t); }));

}
export function marbles(func) {
return _marbles(function (m, t) {
exports.cases = cases;
function marbles(func) {
return marbles_1.marbles(function (m, t) {
m.configure({

@@ -23,1 +30,2 @@ assert: t.ok.bind(t),

}
exports.marbles = marbles;
{
"main": "../bundles/rxjs-marbles-tape.umd.js",
"module": "./index.js",
"typings": "./index.d.ts"
"es2015": "../esm2015/tape/index.js",
"main": "./index.js",
"module": "../esm5/tape/index.js",
"typings": "../index.d.ts"
}

Sorry, the diff of this file is too big to display

Sorry, the diff of this file is too big to display

Sorry, the diff of this file is too big to display

Sorry, the diff of this file is too big to display

Sorry, the diff of this file is too big to display

Sorry, the diff of this file is too big to display

SocketSocket SOC 2 Logo

Product

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

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc