(stream4)
| 12439 | } |
| 12440 | class WritableStreamDefaultWriter2 { |
| 12441 | constructor(stream4) { |
| 12442 | assertRequiredArgument(stream4, 1, "WritableStreamDefaultWriter"); |
| 12443 | assertWritableStream(stream4, "First parameter"); |
| 12444 | if (IsWritableStreamLocked(stream4)) { |
| 12445 | throw new TypeError("This stream has already been locked for exclusive writing by another writer"); |
| 12446 | } |
| 12447 | this._ownerWritableStream = stream4; |
| 12448 | stream4._writer = this; |
| 12449 | const state2 = stream4._state; |
| 12450 | if (state2 === "writable") { |
| 12451 | if (!WritableStreamCloseQueuedOrInFlight(stream4) && stream4._backpressure) { |
| 12452 | defaultWriterReadyPromiseInitialize(this); |
| 12453 | } else { |
| 12454 | defaultWriterReadyPromiseInitializeAsResolved(this); |
| 12455 | } |
| 12456 | defaultWriterClosedPromiseInitialize(this); |
| 12457 | } else if (state2 === "erroring") { |
| 12458 | defaultWriterReadyPromiseInitializeAsRejected(this, stream4._storedError); |
| 12459 | defaultWriterClosedPromiseInitialize(this); |
| 12460 | } else if (state2 === "closed") { |
| 12461 | defaultWriterReadyPromiseInitializeAsResolved(this); |
| 12462 | defaultWriterClosedPromiseInitializeAsResolved(this); |
| 12463 | } else { |
| 12464 | const storedError = stream4._storedError; |
| 12465 | defaultWriterReadyPromiseInitializeAsRejected(this, storedError); |
| 12466 | defaultWriterClosedPromiseInitializeAsRejected(this, storedError); |
| 12467 | } |
| 12468 | } |
| 12469 | /** |
| 12470 | * Returns a promise that will be fulfilled when the stream becomes closed, or rejected if the stream ever errors or |
| 12471 | * the writer’s lock is released before the stream finishes closing. |
nothing calls this directly
no test coverage detected