TypeScript stream.Transform类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› TypeScript›TypeScript教程

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了TypeScript中stream.Transform类的典型用法代码示例。如果您正苦于以下问题：TypeScript Transform类的具体用法？TypeScript Transform怎么用？TypeScript Transform使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

在下文中一共展示了Transform类的9个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的TypeScript代码示例。

示例1: checkFileForChanges

  public async checkFileForChanges(
    transform: Transform,
    file: File,
    enc: string,
    callback: (error: any, data: any) => any,
  ) {
    if (file.isNull()) {
      callback(null, null);
      return;
    }

    try {
      const changed = await this.hasFileOrDependenciesChanged(
        file,
        this.getOutputFileName(file.path),
      );

      if (changed) {
        transform.push(file);
      }
    } catch (error) {
      transform.emit(
        "error",
        new PluginError(
          MODULE_NAME,
          `Error processing \'${file.path}\': ${error}`,
        ),
      );
    } finally {
      callback(null, null);
    }
  }

开发者ID:bingnz，项目名称:gulp-less-changed，代码行数:32，代码来源:main.ts

示例2: createStringStream

function createStringStream() {
    var s = new stream.Transform();
    s._transform = function (data, encoding, callback) {
        callback(null, data);
    };
    s.setEncoding("utf8");
    return s;
}

开发者ID:HardwareProjects，项目名称:node-logger，代码行数:8，代码来源:logger-test.ts

示例3: createDecompressionStream

		static createDecompressionStream(): stream.Transform
		{
			var decompressor = new Decompressor();

			var NodeStream: typeof stream = require("stream");
			var decompressionStream = new NodeStream.Transform({ decodeStrings: true, highWaterMark: 65536 });

			decompressionStream._transform = (data: Buffer, encoding: string, done: Function) =>
			{
				var buffer = decompressor.decompressBlock(convertToByteArray(data));
				decompressionStream.push(buffer);

				done();
			}

			return decompressionStream;
		}

开发者ID:davidamir10，项目名称:lzutf8.js，代码行数:17，代码来源:AsyncDecompressor.ts

示例4: createDecompressionStream

		static createDecompressionStream(): stream.Transform {
			const decompressor = new Decompressor();

			const NodeStream: typeof stream = require("stream");
			const decompressionStream = new NodeStream.Transform({ decodeStrings: true, highWaterMark: 65536 });

			decompressionStream._transform = (data: Buffer, encoding: string, done: Function) => {
				let buffer: Buffer;

				try {
					buffer = BufferTools.uint8ArrayToBuffer(decompressor.decompressBlock(BufferTools.bufferToUint8Array(data)));
				}
				catch (e) {
					decompressionStream.emit("error", e);
					return;
				}

				decompressionStream.push(buffer);

				done();
			}

			return decompressionStream;
		}

开发者ID:rotemdan，项目名称:lzutf8.js，代码行数:24，代码来源:AsyncDecompressor.ts

示例5: StringifyStream

function StringifyStream() {
	stream.Transform.call(this);

	this._readableState.objectMode = false;
	this._writableState.objectMode = true;
}

开发者ID:spidgorny，项目名称:umsaetze，代码行数:6，代码来源:runSpardaBank.ts

示例6: constructor

 constructor(options) {
   super(options);
   Transform.call(Inspector, Transform);
 }

开发者ID:TetuSecurity，项目名称:Crypt，代码行数:4，代码来源:stream_inspector.ts

示例7: TimeoutError

		const handleRequest = (request: http.ClientRequest) => {
			if (shouldAbort) {
				request.abort();
				return;
			}

			currentRequest = request;

			request.on('error', error => {
				if (request.aborted || error.message === 'socket hang up') {
					return;
				}

				if (error instanceof TimedOutTimeoutError) {
					error = new TimeoutError(error, timings, options);
				} else {
					error = new RequestError(error, options);
				}

				if (emitter.retry(error) === false) {
					emitError(error);
				}
			});

			timings = timer(request);

			uploadProgress(request, emitter, uploadBodySize);

			if (options.gotTimeout) {
				// TODO: Properly type this. `preNormalizeArguments` coerces `gotTimeout` to `Delays`.
				timedOut(request, options.gotTimeout as Delays, options);
			}

			emitter.emit('request', request);

			const uploadComplete = () => {
				request.emit('upload-complete');
			};

			try {
				if (is.nodeStream(options.body)) {
					options.body.once('end', uploadComplete);
					options.body.pipe(request);
					options.body = undefined;
				} else if (options.body) {
					request.end(options.body, uploadComplete);
				} else if (input && (options.method === 'POST' || options.method === 'PUT' || options.method === 'PATCH')) {
					input.once('end', uploadComplete);
					input.pipe(request);
				} else {
					request.end(uploadComplete);
				}
			} catch (error) {
				emitError(new RequestError(error, options));
			}
		};

开发者ID:sindresorhus，项目名称:got，代码行数:56，代码来源:request-as-event-emitter.ts

示例8:

			decompressionStream._transform = (data: Buffer, encoding: string, done: Function) => {
				let buffer: Buffer;

				try {
					buffer = BufferTools.uint8ArrayToBuffer(decompressor.decompressBlock(BufferTools.bufferToUint8Array(data)));
				}
				catch (e) {
					decompressionStream.emit("error", e);
					return;
				}

				decompressionStream.push(buffer);

				done();
			}

开发者ID:rotemdan，项目名称:lzutf8.js，代码行数:15，代码来源:AsyncDecompressor.ts

示例9:

			decompressionStream._transform = (data: Buffer, encoding: string, done: Function) =>
			{
				var buffer = decompressor.decompressBlock(convertToByteArray(data));
				decompressionStream.push(buffer);

				done();
			}

开发者ID:davidamir10，项目名称:lzutf8.js，代码行数:7，代码来源:AsyncDecompressor.ts

注：本文中的stream.Transform类示例由纯净天空整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。