| 601 | } |
| 602 | |
| 603 | void AsyncReadableStream::pushEnd() |
| 604 | { |
| 605 | switch (state) |
| 606 | { |
| 607 | case State::CanRead: |
| 608 | case State::Reading: |
| 609 | case State::SyncPushing: |
| 610 | case State::SyncReadMore: |
| 611 | case State::Paused: |
| 612 | case State::AsyncPushing: |
| 613 | case State::AsyncReading: |
| 614 | case State::Pausing: |
| 615 | // In all these state we can just end directly |
| 616 | state = State::Ended; |
| 617 | eventEnd.emit(); |
| 618 | maybeDestroyEndedReadable(); |
| 619 | break; |
| 620 | case State::Destroying: emitError(Result::Error("AsyncReadableStream::pushEnd - stream is destroying")); break; |
| 621 | case State::Ended: emitError(Result::Error("AsyncReadableStream::pushEnd - stream already ended")); break; |
| 622 | case State::Stopped: emitError(Result::Error("AsyncReadableStream::pushEnd - stream is not even inited")); break; |
| 623 | case State::Errored: emitError(Result::Error("AsyncReadableStream::pushEnd - stream is in error state")); break; |
| 624 | } |
| 625 | } |
| 626 | |
| 627 | AsyncBuffersPool& AsyncReadableStream::getBuffersPool() { return *buffers; } |
| 628 |
no test coverage detected