cycle-grid-driver
Advanced tools
Comparing version 0.0.31 to 0.0.32
@@ -28,4 +28,4 @@ 'use strict'; | ||
grid.streams.push({ stream$: stream$, meta: meta }); | ||
grid.pushToGrid([stream$, meta]); | ||
window.grid.streams.push({ stream$: stream$, meta: meta }); | ||
window.grid.pushToGrid([stream$, meta]); | ||
} else { | ||
@@ -87,3 +87,3 @@ throw new Error('Unsupported stream sent to grid'); | ||
return grid.main$.filter(function (_ref) { | ||
return window.grid.main$.filter(function (_ref) { | ||
var _ref2 = _slicedToArray(_ref, 2); | ||
@@ -97,5 +97,5 @@ | ||
for (var i in grid.streams) { | ||
if (shouldStreamMerge(grid.streams[i].meta, filter)) { | ||
streams.push(grid.streams[i].stream$); | ||
for (var i in window.grid.streams) { | ||
if (shouldStreamMerge(window.grid.streams[i].meta, filter)) { | ||
streams.push(window.grid.streams[i].stream$); | ||
} | ||
@@ -123,7 +123,7 @@ } | ||
var grid = { | ||
window.grid = { | ||
// main grid stream | ||
main$: _xstream2.default.create({ | ||
start: function start(listener) { | ||
grid.pushToGrid = function (data) { | ||
window.grid.pushToGrid = function (data) { | ||
listener.next(data); | ||
@@ -133,3 +133,3 @@ }; | ||
stop: function stop() { | ||
grid.pushToGrid = function () {}; | ||
window.grid.pushToGrid = function () {}; | ||
} | ||
@@ -136,0 +136,0 @@ }), |
{ | ||
"name": "cycle-grid-driver", | ||
"version": "0.0.31", | ||
"version": "0.0.32", | ||
"description": "cycle.js grid driver", | ||
@@ -5,0 +5,0 @@ "main": "dist/index.js", |
import xs from 'xstream'; | ||
const grid = { | ||
window.grid = { | ||
// main grid stream | ||
main$: xs.create({ | ||
start: listener => { | ||
grid.pushToGrid = data => { | ||
window.grid.pushToGrid = data => { | ||
listener.next(data) | ||
@@ -12,3 +12,3 @@ } | ||
stop: () => { | ||
grid.pushToGrid = function () { }; | ||
window.grid.pushToGrid = function () { }; | ||
} | ||
@@ -32,4 +32,4 @@ }), | ||
grid.streams.push({ stream$, meta }); | ||
grid.pushToGrid([stream$, meta]); | ||
window.grid.streams.push({ stream$, meta }); | ||
window.grid.pushToGrid([stream$, meta]); | ||
} else { | ||
@@ -76,3 +76,3 @@ throw new Error('Unsupported stream sent to grid') | ||
return grid.main$ | ||
return window.grid.main$ | ||
.filter(([stream$, meta]) => shouldStreamMerge(meta, filter)) | ||
@@ -82,5 +82,5 @@ .map(() => { | ||
for (let i in grid.streams) { | ||
if (shouldStreamMerge(grid.streams[i].meta, filter)) { | ||
streams.push(grid.streams[i].stream$); | ||
for (let i in window.grid.streams) { | ||
if (shouldStreamMerge(window.grid.streams[i].meta, filter)) { | ||
streams.push(window.grid.streams[i].stream$); | ||
} | ||
@@ -87,0 +87,0 @@ } |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
8413