ReadableStream.ReadableStream()

ReadableStream() 构造器创建并返回包含处理函数的可读流实例.

var readableStream = new ReadableStream(underlyingSource[, queueingStrategy]);

underlyingSource

一个包含定义了构造流行为方法和属性的对象.underlyingSource 包括:

start(controller)

这是一个当对象被构造时立刻调用的方法.此方法的内容由开发人员定义，并应着眼于访问流,并执行其他任何必需的设置流功能.如果这个过程是异步完成的，它可以返回一个promise，表明成功或失败.传递给这个方法的controller是一个ReadableStreamDefaultController或ReadableByteStreamController,具体取决于type属性的值。开发人员可以使用此方法在设立期间控制流.

pull(controller) 可选

这个方法，也是由开发人员定义的，当流的内部队列不满时，会重复调用这个方法，直到队列补满。如果pull()返回一个promise，那么它将不会再被调用，直到promise完成;如果promise失败，该流将会出现错误.传递给此方法的controller参数是ReadableStreamDefaultController或ReadableByteStreamController,具体取决于type属性的值。由于更多的块被获取,这个方法可以被开发人员用来控制流.

cancel(reason) 可选

如果应用程序表示该流将被取消（例如,调用了ReadableStream.cancel()，则将调用此方法，该方法也由开发人员定义。 该方法应该做任何必要的事情来释放对流的访问。 如果这个过程是异步的，它可以返回一个promise,表明成功或失败.原因参数包含一个DOMString,它描述了流被取消的原因.

type 可选

该属性控制正在处理的可读类型的流。如果它包含一个设置为bytes的值，则传递的控制器对象将是一个ReadableByteStreamController，能够处理BYOB（带您自己的缓冲区）/字节流。如果未包含，则传递的控制器将为ReadableStreamDefaultController。

autoAllocateChunkSize 可选

对于字节流，开发人员可以使用正整数值设置autoAllocateChunkSize 以打开流的自动分配功能。启用此功能后，流实现将自动分配一个具有给定整数大小的ArrayBuffer，并调用底层源代码，就好像消费者正在使用BYOB阅读器一样。

queueingStrategy 可选

一个可选择定义流的排队策略的对象。这需要两个参数：

highWaterMark

非负整数 - 这定义了在应用背压之前可以包含在内部队列中的块的总数。

size(chunk)

包含参数chunk 的方法 - 这表示每个块使用的大小（以字节为单位）.

Note: You could define your own custom queueingStrategy, or use an instance of ByteLengthQueueingStrategy or CountQueueingStrategy for this object value. If no queueingStrategy is supplied, the default used is the same as a CountQueuingStrategy with a high water mark of 1.

ReadableStream对象的实例.

RangeError

提供的值既不是bytes也不是undefined.

In the following simple example, a custom ReadableStream is created using a constructor (see our Simple random stream example for the full code). The start() function generates a random string of text every second and enqueues it into the stream. A cancel() fuction is also provided to stop the generation if ReadableStream.cancel() is called for any reason.

When a button is pressed, the generation is stopped, the stream is closed using ReadableStreamDefaultController.close(), and another function is run, which reads the data back out of the stream.

const stream = new ReadableStream({
  start(controller) {
    interval = setInterval(() => {
      let string = randomChars();

      // Add the string to the stream
      controller.enqueue(string);

      // show it on the screen
      let listItem = document.createElement('li');
      listItem.textContent = string;
      list1.appendChild(listItem);
    }, 1000);

    button.addEventListener('click', function() {
      clearInterval(interval);
      fetchStream();
      controller.close();
    })
  },
  pull(controller) {
    // We don't really need a pull in this example
  },
  cancel() {
    // This is called if the reader cancels,
    // so we should stop generating strings
    clearInterval(interval);
  }
});