TypeScript WritableStream.write函数代码示例

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

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

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

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

示例1: function

			return stream.close().then(function () {
				assert.strictEqual(stream.state, State.Closed, 'Stream should be in closed state');

				return stream.write('abc').then(function () {
					assert.fail(null, null, 'Write operation on closed stream should not succeed');
				}, function (error: Error) {
					assert.strictEqual(stream.state, State.Closed, 'Stream should be in closed state');
				});
			});

开发者ID:GionHobby，项目名称:core，代码行数:9，代码来源:WritableStream.ts

示例2: registerSuite

import { getApproximateByteSize } from 'src/streams/util';

const ASYNC_TIMEOUT = 1000;

registerSuite({
	name: 'ByteLengthQueuingStrategy',

	size() {
		let dfd = this.async(ASYNC_TIMEOUT);
		let sink = new ManualSink<ArrayBuffer>();

		let stream = new WritableStream<ArrayBuffer>(sink, new ByteLengthQueuingStrategy<ArrayBuffer>({
			highWaterMark: 2 * 1024
		}));

		let promise = stream.write(new ArrayBuffer(1024));
		assert.strictEqual(stream.state, State.Writable);

		stream.write(new ArrayBuffer(1024));
		assert.strictEqual(stream.state, State.Writable);

		stream.write(new ArrayBuffer(1));
		assert.strictEqual(stream.state, State.Waiting);

		setTimeout(function () {
			sink.next();
		}, 20);

		promise.then(dfd.callback(function () {
			assert.strictEqual(stream.state, State.Writable);
		}), function (error: Error) {

开发者ID:jdonaghue，项目名称:core，代码行数:31，代码来源:ByteLengthQueuingStrategy.ts

示例3: registerSuite

import ManualSink from './helpers/ManualSink';

const ASYNC_TIMEOUT = 1000;

registerSuite({
	name: 'CountQueuingStrategy',

	size(this: any) {
		let dfd = this.async(ASYNC_TIMEOUT);
		let sink = new ManualSink<string>();

		let stream = new WritableStream<string>(sink, new CountQueuingStrategy<string>({
			highWaterMark: 2
		}));

		let promise = stream.write('test value 1');
		assert.strictEqual(stream.state, State.Writable);

		stream.write('test value 2');
		assert.strictEqual(stream.state, State.Writable);

		stream.write('test value 3');
		assert.strictEqual(stream.state, State.Waiting);

		setTimeout(function () {
			sink.next();
		}, 20);

		promise.then(dfd.callback(function () {
			assert.strictEqual(stream.state, State.Writable);
		}), function (error: Error) {

开发者ID:GionHobby，项目名称:core，代码行数:31，代码来源:CountQueuingStrategy.ts

示例4: Error

				return Promise.reject(new Error('test error'));
			};

			stream = new WritableStream(sink, strategy);

			stream.close().then(function () {
				dfd.reject(new Error('stream.close should reject with error'));
			}, dfd.callback(function (error: Error) {
				assert.strictEqual(stream.state, State.Errored);
			}));
		},

		'blocks write'() {
			stream.close();

			return stream.write('abc').then(function () {
				throw new Error('Closed stream should not be writable');
			}, function (error: Error) {
				return;
			});
		},

		'calls sink.close'(this: any) {
			let dfd = this.async(ASYNC_TIMEOUT);

			sink.close = dfd.callback(function () {});
			stream = new WritableStream(sink, strategy);
			stream.close();
		},

		'handles sink.close error'() {

开发者ID:GionHobby，项目名称:core，代码行数:31，代码来源:WritableStream.ts

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