Method destroy

Libraries/AsyncStreams/AsyncStreams.cpp:522–554

}

void AsyncReadableStream::destroy()
{
    // Empty all queued buffers
    Request request;
    while (readQueue.popFront(request))
    {
        buffers->unrefBuffer(request.bufferID); // 1b. refBuffer in push
    }
    switch (state)
    {
    case State::CanRead:
    case State::SyncPushing:
    case State::SyncReadMore:
    case State::Paused:
    case State::Pausing:
    case State::Reading:
    case State::AsyncPushing:
    case State::AsyncReading:
    case State::Stopped:
    case State::Ended: {
        state      = State::Destroying;
        Result res = asyncDestroyReadable();
        if (not res)
        {
            state = State::Errored;
            eventError.emit(res);
        }
        break;
    }
    case State::Destroying:
    case State::Errored: break;
    }
}

Result AsyncReadableStream::finishedDestroyingReadable()
{