{"version":3,"sources":["/Users/kevin/Dev/OpenSource/iterators/fast-extract/src/streams/transforms/PathToData.mjs"],"sourcesContent":["import fs from 'fs';\nimport { Transform } from 'stream';\nimport oo from 'on-one';\n\nexport default class PathToData extends Transform {\n  constructor(options) {\n    super(options || {});\n  }\n\n  _transform(chunk, _encoding, callback) {\n    const self = this;\n    const fullPath = typeof chunk === 'string' ? chunk : chunk.toString();\n    const stream = fs.createReadStream(fullPath);\n    stream.on('data', function data(chunk) {\n      self.push(chunk, 'buffer');\n    });\n    oo(stream, ['error', 'end', 'close', 'finish'], (err) => {\n      !err || self.push(null);\n      callback(err);\n    });\n  }\n}\n"],"names":["PathToData","options","_transform","chunk","_encoding","callback","self","fullPath","toString","stream","fs","createReadStream","on","data","push","oo","err","Transform"],"mappings":";;;;;;;eAIqBA;;;yDAJN;sBACW;4DACX;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAEA,IAAA,AAAMA,2BAAN;;cAAMA;aAAAA,WACPC,OAAO;gCADAD;QAEjB,OAAA,kBAFiBA;YAEXC,WAAW,CAAC;;;iBAFDD;IAKnBE,OAAAA,UAWC,GAXDA,SAAAA,WAAWC,KAAK,EAAEC,SAAS,EAAEC,QAAQ;QACnC,IAAMC,OAAO,IAAI;QACjB,IAAMC,WAAW,OAAOJ,UAAU,WAAWA,QAAQA,MAAMK,QAAQ;QACnE,IAAMC,SAASC,WAAE,CAACC,gBAAgB,CAACJ;QACnCE,OAAOG,EAAE,CAAC,QAAQ,SAASC,KAAKV,KAAK;YACnCG,KAAKQ,IAAI,CAACX,OAAO;QACnB;QACAY,IAAAA,cAAE,EAACN,QAAQ;YAAC;YAAS;YAAO;YAAS;SAAS,EAAE,SAACO;YAC/C,CAACA,OAAOV,KAAKQ,IAAI,CAAC;YAClBT,SAASW;QACX;IACF;WAhBmBhB;EAAmBiB,iBAAS"}