test(node): add test for multiple copies of rxjs error

node-tests/run.sh

@@ -0,0 +1,16 @@
+
+rm -rf node-tests/node_modules/
+
+mkdir -p node-tests/node_modules/rxjs
+mkdir -p node-tests/node_modules/rxjs1
+
+cp -R dist/package/. node-tests/node_modules/rxjs
+cp -R dist/package/. node-tests/node_modules/rxjs1
+
+{
+   node node-tests/test.js
+  # node --inspect-brk node-tests/test.js
+} || {
+  echo 'TEST FAILED'
+}
+

node-tests/test.js

@@ -0,0 +1,34 @@
+
+var rxjs = require('rxjs');
+var rxjs1 = require('rxjs1');
+var mergeMap = require('rxjs/operators').mergeMap;
+var mergeMap1 = require('rxjs1/operators').mergeMap;
+
+var of = rxjs.of;
+var of1 = rxjs1.of;
+var from1 = rxjs1.from;
+
+var actual = [];
+var expected = [1];
+
+var id = setTimeout(function () {
+  throw new Error('TIMEOUT: Observable did not complete');
+}, 200);
+
+of1(0).pipe(
+  mergeMap1(function () { return of(x); }),
+  mergeMap(function () { return from1(Promise.resolve(1)); })
+).subscribe({
+  next: function (value) { actual.push(value); },
+  error: function () {
+    throw new Error('should not error');
+  },
+  complete: function () {
+    if (actual.length !== expected.length || actual[0] !== expected[0] || actual[1] !== expected[1]) {
+      throw new Error(actual + ' does not equal ' + expected);
+    } else {
+      clearTimeout(id);
+      console.log('TEST PASSED');
+    }
+  },
+});