Lines Matching refs:_state

5606       this._state = 'writable';
5703 var state = stream._state;
5745 assert(stream._state === 'writable');
5758 var state = stream._state;
5771 assert(stream._state === 'writable', 'state must be writable');
5774 stream._state = 'erroring';
5788 assert(stream._state === 'erroring', 'stream._state === erroring');
5790 stream._state = 'errored';
5846 assert(stream._state === 'writable' || stream._state === 'erroring');
5856 var state = stream._state;
5869 stream._state = 'closed';
5886 assert(stream._state === 'writable' || stream._state === 'erroring');
5927 assert(stream._state === 'errored', '_stream_.[[state]] is `"errored"`');
5947 assert(stream._state === 'writable');
5977 var state = stream._state;
6127 var state = stream._state;
6154 var state = stream._state;
6190 var state = stream._state;
6224 var state = stream._state;
6276 var state = this._controlledWritableStream._state;
6302 assert(stream._state === 'writable' || stream._state === 'erroring');
6306 assert(stream._state === 'writable' || stream._state === 'erroring');
6354 if (WritableStreamCloseQueuedOrInFlight(stream) === false && stream._state === 'writable') {
6385 var state = stream._state;
6410 if (controller._controlledWritableStream._state === 'writable') {
6434 var state = stream._state;
6456 assert(stream._state === 'writable');
6709 this._state = 'readable';
6862 if (WritableStreamCloseQueuedOrInFlight(dest) === true || dest._state === 'closed') {
6887 if (stream._state === 'errored') {
6895 if (stream._state === 'closed') {
6909 if (dest._state === 'writable' && WritableStreamCloseQueuedOrInFlight(dest) === false) {
6931 if (dest._state === 'writable' && WritableStreamCloseQueuedOrInFlight(dest) === false) {
7154 assert(stream._state === 'readable' || stream._state === 'closed');
7168 assert(stream._state === 'readable');
7183 if (stream._state === 'closed') {
7187 if (stream._state === 'errored') {
7201 assert(stream._state === 'readable');
7202 stream._state = 'closed';
7225 assert(stream._state === 'readable', 'state must be readable');
7226 stream._state = 'errored';
7499 if (stream._state === 'readable') {
7501 } else if (stream._state === 'closed') {
7504 assert(stream._state === 'errored', 'state must be errored');
7521 if (reader._ownerReadableStream._state === 'readable') {
7538 if (stream._state === 'errored') {
7550 if (stream._state === 'closed') {
7554 if (stream._state === 'errored') {
7558 assert(stream._state === 'readable');
7609 var state = this._controlledReadableStream._state;
7628 var state = this._controlledReadableStream._state;
7645 if (stream._state !== 'readable') {
7646 throw new TypeError('The stream is ' + stream._state + ' and so cannot be errored');
7737 if (stream._state === 'closed' || stream._state === 'errored') {
7765 assert(stream._state === 'readable');
7776 assert(stream._state === 'readable');
7808 assert(stream._state === 'readable');
7814 if (controller._controlledReadableStream._state === 'readable') {
7821 var state = stream._state;
7922 if (stream._state === 'readable') {
7939 var state = this._controlledReadableStream._state;
7958 var state = this._controlledReadableStream._state;
7979 if (stream._state !== 'readable') {
7980 throw new TypeError('The stream is ' + stream._state + ' and so cannot be errored');
8124 if (controller._controlledReadableStream._state === 'readable') {
8137 assert(stream._state !== 'errored', 'state must not be errored');
8140 if (stream._state === 'closed') {
8223 assert(controller._controlledReadableStream._state === 'readable');
8286 if (stream._state === 'closed') {
8357 if (stream._state === 'closed') {
8364 assert(stream._state === 'readable');
8379 if (stream._state !== 'readable') {
8409 assert(stream._state === 'readable');
8432 assert(stream._state === 'readable');
8457 assert(stream._state === 'readable');
8465 var state = stream._state;