Skip to content
Commits on Source (2)
{
"name": "i4-js-commons",
"version": "3.9.2",
"version": "3.9.3",
"lockfileVersion": 1,
"requires": true,
"dependencies": {
......
{
"name": "i4-js-commons",
"version": "3.9.2",
"version": "3.9.3",
"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",
......
......@@ -244,7 +244,6 @@ export const fromChannels = async ({
lengths = [],
}) => {
let counts = lengths;
console.log('counts:', counts);
console.log('typeDocs:', typeDocs);
console.log('ttl:', ttl);
if (historyCb || ttl || from || to || noSub) {
......@@ -269,6 +268,7 @@ export const fromChannels = async ({
const value = dataInPoint(path, point);
return Array.isArray(value) ? value.length : 1;
}); // -> [1, 2, 1, 1]
console.log('counts:', counts);
const merged = datasetMerge(counts, histories);
console.log('merged:', merged);
if (historyCb) historyCb(merged);
......@@ -279,8 +279,9 @@ export const fromChannels = async ({
? undefined
: Promise.all(
channels.map(({ rid, type, path }, idx) => {
console.log('Sub-ing 1:', rid, type, path, counts, idx);
const [before, [_, ...after]] = R.splitAt(idx)(counts); // eslint-disable-line no-unused-vars
console.log('Sub-ing:', rid, type, path, before, after, idx);
console.log('Sub-ing 2:', before, after);
const callback = R.compose(cb, conformPoint(before, after, path));
return fromChannel({
rid,
......