/*

 * Copyright (c) 2023, Shannon Booth <shannon@serenityos.org>

 *

 * SPDX-License-Identifier: BSD-2-Clause

 */

#pragma once

#include <AK/Forward.h>

#include <LibJS/Forward.h>

#include <LibWeb/Bindings/PlatformObject.h>

#include <LibWeb/Forward.h>

#include <LibWeb/Streams/QueuingStrategyInit.h>

namespace Web::Streams {

// https://streams.spec.whatwg.org/#countqueuingstrategy

class CountQueuingStrategy final : public Bindings::PlatformObject {

    WEB_PLATFORM_OBJECT(CountQueuingStrategy, Bindings::PlatformObject);

    JS_DECLARE_ALLOCATOR(CountQueuingStrategy);

public:

    static JS::NonnullGCPtr<CountQueuingStrategy> construct_impl(JS::Realm&, QueuingStrategyInit const&);

    virtual ~CountQueuingStrategy() override;

    // https://streams.spec.whatwg.org/#cqs-high-water-mark

    double high_water_mark() const

    {

        // The highWaterMark getter steps are:

        // 1. Return this.[[highWaterMark]].

        return m_high_water_mark;

    }

    JS::NonnullGCPtr<WebIDL::CallbackType> size();

private:

    explicit CountQueuingStrategy(JS::Realm&, double high_water_mark);

    virtual void initialize(JS::Realm&) override;

    // https://streams.spec.whatwg.org/#countqueuingstrategy-highwatermark

    double m_high_water_mark { 0 };

};

}