Skip to content
Commits on Source (2)
{
"name": "i4-js-commons",
"version": "3.9.0",
"version": "3.9.1",
"lockfileVersion": 1,
"requires": true,
"dependencies": {
......
{
"name": "i4-js-commons",
"version": "3.9.0",
"version": "3.9.1",
"description": "Just a load of common stuff for i4 front-ends and some probably usable in back-end as well",
"dependencies": {
"@material-ui/core": "^4.7.2",
......
......@@ -258,6 +258,7 @@ export const fromChannels = async ({
}).then(data => ({ path, data })),
),
); // -> [[{ts, pl}, {ts, pl}], [{ts, pl}]]
console.log('histories:', histories);
/* eslint-disable no-param-reassign */
counts =
lengths ||
......@@ -266,6 +267,7 @@ export const fromChannels = async ({
return Array.isArray(value) ? value.length : 1;
}); // -> [1, 2, 1, 1]
const merged = datasetMerge(counts, histories);
console.log('merged:', merged);
if (historyCb) historyCb(merged);
else if (cb) merged.map(cb);
if (noSub) return merged;
......@@ -275,6 +277,7 @@ export const fromChannels = async ({
: Promise.all(
channels.map(({ rid, type, path }, idx) => {
const [before, [_, ...after]] = R.splitAt(idx)(counts); // eslint-disable-line no-unused-vars
console.log('Sub-ing:', rid, type, path, before, after, idx);
const callback = R.compose(cb, conformPoint(before, after, path));
return fromChannel({
rid,
......