reducerResult = Generators.queue(
worker(
function dr({ method, data, parameters }) {
const D = new druid[method](data, parameters);
const next = D.generator().next();
if (next.done) {
return D.transform();
}
return D.generator();
},
{
method: druid_method,
data: embeddings.map((row) => row.data),
parameters: reducerParams
},
`
importScripts(${JSON.stringify(
await require.resolve("@saehrimnir/druidjs@0.6.3")
)});
`
)
)