Method write

Libraries/AsyncStreams/AsyncStreams.cpp:687–703

AsyncWritableStream::~AsyncWritableStream() {}

Result AsyncWritableStream::write(AsyncBufferView::ID bufferID, Function<void(AsyncBufferView::ID)> cb)
{
    if (state == State::Ended or state == State::Ending)
    {
        return Result::Error("AsyncWritableStream::write - failed (ending or ended state)");
    }
    Request request;
    request.bufferID = bufferID;
    request.cb       = move(cb);
    if (not writeQueue.pushBack(request))
    {
        return Result::Error("AsyncWritableStream::write - queue is full");
    }
    buffers->refBuffer(bufferID); // 2a. unrefBuffer below or in finishedWriting
    resumeWriting();
    return Result(true);
}

Result AsyncWritableStream::write(AsyncBufferView&& bufferView, Function<void(AsyncBufferView::ID)> cb)
{