aboutsummaryrefslogtreecommitdiffstats
path: root/node_modules/iconv-lite/lib/streams.js
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--node_modules/iconv-lite/lib/streams.js105
1 files changed, 0 insertions, 105 deletions
diff --git a/node_modules/iconv-lite/lib/streams.js b/node_modules/iconv-lite/lib/streams.js
deleted file mode 100644
index ebfed8e..0000000
--- a/node_modules/iconv-lite/lib/streams.js
+++ /dev/null
@@ -1,105 +0,0 @@
-"use strict"
-
-var Buffer = require("safer-buffer").Buffer
-
-// NOTE: Due to 'stream' module being pretty large (~100Kb, significant in browser environments),
-// we opt to dependency-inject it instead of creating a hard dependency.
-module.exports = function (streamModule) {
- var Transform = streamModule.Transform
-
- // == Encoder stream =======================================================
-
- function IconvLiteEncoderStream (conv, options) {
- this.conv = conv
- options = options || {}
- options.decodeStrings = false // We accept only strings, so we don't need to decode them.
- Transform.call(this, options)
- }
-
- IconvLiteEncoderStream.prototype = Object.create(Transform.prototype, {
- constructor: { value: IconvLiteEncoderStream }
- })
-
- IconvLiteEncoderStream.prototype._transform = function (chunk, encoding, done) {
- if (typeof chunk !== "string") {
- return done(new Error("Iconv encoding stream needs strings as its input."))
- }
-
- try {
- var res = this.conv.write(chunk)
- if (res && res.length) this.push(res)
- done()
- } catch (e) {
- done(e)
- }
- }
-
- IconvLiteEncoderStream.prototype._flush = function (done) {
- try {
- var res = this.conv.end()
- if (res && res.length) this.push(res)
- done()
- } catch (e) {
- done(e)
- }
- }
-
- IconvLiteEncoderStream.prototype.collect = function (cb) {
- var chunks = []
- this.on("error", cb)
- this.on("data", function (chunk) { chunks.push(chunk) })
- this.on("end", function () {
- cb(null, Buffer.concat(chunks))
- })
- return this
- }
-
- // == Decoder stream =======================================================
-
- function IconvLiteDecoderStream (conv, options) {
- this.conv = conv
- options = options || {}
- options.encoding = this.encoding = "utf8" // We output strings.
- Transform.call(this, options)
- }
-
- IconvLiteDecoderStream.prototype = Object.create(Transform.prototype, {
- constructor: { value: IconvLiteDecoderStream }
- })
-
- IconvLiteDecoderStream.prototype._transform = function (chunk, encoding, done) {
- if (!Buffer.isBuffer(chunk) && !(chunk instanceof Uint8Array)) { return done(new Error("Iconv decoding stream needs buffers as its input.")) }
- try {
- var res = this.conv.write(chunk)
- if (res && res.length) this.push(res, this.encoding)
- done()
- } catch (e) {
- done(e)
- }
- }
-
- IconvLiteDecoderStream.prototype._flush = function (done) {
- try {
- var res = this.conv.end()
- if (res && res.length) this.push(res, this.encoding)
- done()
- } catch (e) {
- done(e)
- }
- }
-
- IconvLiteDecoderStream.prototype.collect = function (cb) {
- var res = ""
- this.on("error", cb)
- this.on("data", function (chunk) { res += chunk })
- this.on("end", function () {
- cb(null, res)
- })
- return this
- }
-
- return {
- IconvLiteEncoderStream: IconvLiteEncoderStream,
- IconvLiteDecoderStream: IconvLiteDecoderStream
- }
-}