2

我有这个代码：

import * as stream from 'stream';    

export class JSONParser extends stream.Transform {

  lastLineData = '';
  objectMode = true;

  constructor() {
    super();

  }

  transform(chunk, encoding, cb) {

    let data = String(chunk);
    if (this.lastLineData) {
      data = this.lastLineData + data;
    }

    let lines = data.split('\n');
    this.lastLineData = lines.splice(lines.length - 1, 1)[0];

    lines.forEach(l => {
      try {
        // l might be an empty string; ignore if so
        l && this.push(JSON.parse(l));
      }
      catch (err) {
        // noop
      }
    });

    cb();

  }

  flush(cb) {
    if (this.lastLineData) {
      try {
        this.push(JSON.parse(this.lastLineData));
      }
      catch (err) {
        // noop
      }
    }
    this.lastLineData = '';
    cb();
  }


}

问题是TS 类型不能识别（原型）方法。我是否错误地扩展了 Transform 类？

这是问题所在：

在此处输入图像描述

请注意，这是正确的：

import * as stream from 'stream';

//////////////////////////////////////////////////

export interface IParsedObject {
  [index: string]: any
}

export const createParser = function () {

  let lastLineData = '';

  return new stream.Transform({

    objectMode: true,

    transform(chunk: any, encoding: string, cb: Function) {

      let data = String(chunk);
      if (lastLineData) {
        data = lastLineData + data;
      }

      let lines = data.split('\n');
      lastLineData = lines.splice(lines.length - 1, 1)[0];

      lines.forEach(l => {
        try {
          // l might be an empty string; ignore if so
          l && this.push(JSON.parse(l));
        }
        catch (err) {
          // noop
        }
      });

      cb();

    },

    flush(cb: Function) {
      if (lastLineData) {
        try {
          this.push(JSON.parse(lastLineData));
        }
        catch (err) {
          // noop
        }
      }
      lastLineData = '';
      cb();
    }
  });

};

但上面的课程似乎不一样。

4

2 回答 2

3

在您的屏幕截图中，您试图扩展Transform类，但您没有实现正确的方法，您应该实现transform._transform(chunk, encoding, callback)，然后打字稿将自动推断所需的类型。由于类型transform.transform(chunk, encoding, callback)上不存在Transformtypescript 没有可用于推理的类型，因此编译器会生成警告。

在您的代码示例中，您选择使用“简化”Transform构造函数。构造函数采用一组选项，允许您在不显式扩展类的情况下定义必要的转换方法。这些选项选择不带下划线前缀的命名约定，但在扩展类时它们等效于带下划线前缀的方法。由于您在这里使用了正确的方法名称，因此可以推断出类型。

TransformAPI 调用了三种方法的实现，这些方法在此处进行了概述。

有两种实现Transform流的方法：

  1. 扩展Transform类
  2. 使用Transform构造函数选项。

此处概述了这两种方法（包括在 ES6 之前的环境中扩展类的示例）。

实现Transform流时，只需实现一种方法：

  1. transform._transform(chunk, encoding, callback)

其他两种方法是可选的，如果用例需要，可以实现：

  1. transform._flush(callback)
  2. writable._final(callback)

我已经继续并概述了Transform下面记录的方法，突出了一些可能感兴趣的领域。

transform._flush(callback)

此函数不得由应用程序代码直接调用。它应该由子类实现，并且只能由内部 Readable 类方法调用。

在某些情况下，转换操作可能需要在流的末尾发出额外的数据位。例如，zlib 压缩流将存储用于优化压缩输出的大量内部状态。但是，当流结束时，需要刷新附加数据，以便完成压缩数据。

自定义 Transform 实现可以实现 transform._flush() 方法。这将在没有更多写入数据被使用时调用，但在发出“end”事件之前，表示可读流的结束。

在 transform._flush() 实现中， readable.push() 方法可以被调用零次或多次，视情况而定。刷新操作完成后必须调用回调函数。

transform._flush() 方法以下划线为前缀，因为它是定义它的类的内部，不应由用户程序直接调用。

transform._transform(chunk, encoding, callback)

此函数不得由应用程序代码直接调用。它应该由子类实现，并且只能由内部 Readable 类方法调用。

所有的 Transform 流实现都必须提供一个 _transform() 方法来接受输入并产生输出。transform._transform() 实现处理正在写入的字节，计算输出，然后使用 readable.push() 方法将该输出传递给可读部分。

transform.push() 方法可能会被调用零次或多次以从单个输入块生成输出，具体取决于作为块的结果要输出多少。

任何给定的输入数据块都可能不会产生任何输出。

只有当当前块完全消耗时，才必须调用回调函数。如果在处理输入时发生错误，则传递给回调的第一个参数必须是 Error 对象，否则为 null。如果将第二个参数传递给回调，它将被转发到 readable.push() 方法。换句话说，以下是等价的：

transform.prototype._transform = function(data, encoding, callback) {
  this.push(data);
  callback();
};

transform.prototype._transform = function(data, encoding, callback) {
  callback(null, data);
};

transform._transform() 方法以下划线为前缀，因为它是定义它的类的内部，不应由用户程序直接调用。

transform._transform() 永远不会被并行调用；流实现了队列机制，为了接收下一个块，必须调用回调，同步或异步。

writable._final(callback)

_final() 方法不得直接调用。它可能由子类实现，如果是这样，将仅由内部 Writable 类方法调用。

这个可选函数将在流关闭之前被调用，延迟“完成”事件直到回调被调用。这对于在流结束之前关闭资源或写入缓冲数据很有用。

于 2018-09-19T06:02:12.997 回答
1

好的，现在它似乎可以工作了，我必须将构造函数选项传递给super()，所以它变成了super({objectMode:true})，

export class JSONParser extends stream.Transform {

  lastLineData = '';

  constructor() {
    super({objectMode: true});

  }

  _transform(chunk: any, encoding: string, cb: Function) {

    let data = String(chunk);
    if (this.lastLineData) {
      data = this.lastLineData + data;
    }

    let lines = data.split('\n');
    this.lastLineData = lines.splice(lines.length - 1, 1)[0];

    lines.forEach(l => {
      try {
        // l might be an empty string; ignore if so
        l && this.push(JSON.parse(l));
      }
      catch (err) {
        // noop
      }
    });

    cb();

  }

  flush(cb: Function) {
    if (this.lastLineData) {
      try {
        this.push(JSON.parse(this.lastLineData));
      }
      catch (err) {
        // noop
      }
    }
    this.lastLineData = '';
    cb();
  }

  _flush(cb: Function) {
    if (this.lastLineData) {
      try {
        this.push(JSON.parse(this.lastLineData));
      }
      catch (err) {
        // noop
      }
    }
    this.lastLineData = '';
    cb();
  }

}

剩下的唯一问题是我是否应该实施_flush()或者flush()，我不确定......我现在都实施了......

于 2018-09-18T23:20:28.683 回答