diff --git a/taxonium_component/src/webworkers/localBackendWorker.js b/taxonium_component/src/webworkers/localBackendWorker.js index f9682c2d..8328d08a 100644 --- a/taxonium_component/src/webworkers/localBackendWorker.js +++ b/taxonium_component/src/webworkers/localBackendWorker.js @@ -7,7 +7,7 @@ import { import { processNewickAndMetadata } from "../utils/processNewick.js"; import { processNextstrain } from "../utils/processNextstrain.js"; import { ReadableWebToNodeStream } from "readable-web-to-node-stream"; -import StreamValues from 'stream-json/streamers/StreamValues'; +import StreamValues from "stream-json/streamers/StreamValues"; console.log("worker starting"); postMessage({ data: "Worker starting" }); diff --git a/taxonium_data_handling/importing.js b/taxonium_data_handling/importing.js index 04c0dfbc..a46eeeb4 100644 --- a/taxonium_data_handling/importing.js +++ b/taxonium_data_handling/importing.js @@ -65,7 +65,12 @@ function reduceMaxOrMin(array, accessFunction, maxOrMin) { } } -export const setUpStream = (the_stream, data, sendStatusMessage, StreamValues) => { +export const setUpStream = ( + the_stream, + data, + sendStatusMessage, + StreamValues +) => { const splitter = new StreamSplitter(); // Custom header parser using json-stream @@ -162,7 +167,8 @@ export const setUpStream = (the_stream, data, sendStatusMessage, StreamValues) = export const processJsonl = async ( jsonl, sendStatusMessage, - ReadableWebToNodeStream, StreamValues + ReadableWebToNodeStream, + StreamValues ) => { console.log( "Worker processJsonl" //, jsonl @@ -178,7 +184,7 @@ export const processJsonl = async ( the_stream = new stream.PassThrough(); } let new_data = {}; - setUpStream(the_stream, new_data, sendStatusMessage,StreamValues); + setUpStream(the_stream, new_data, sendStatusMessage, StreamValues); if (status === "loaded") { const dataAsArrayBuffer = data;