Stream.h

/* Copyright (C) 2026 by Marc Boris Duerner
   SPDX-License-Identifier: LGPL-2.1-or-later WITH mif-exception
*/
 
#ifndef PT_HTTP_STREAM_H
#define PT_HTTP_STREAM_H
 
#include <Pt/Http/Api.h>
#include <Pt/Connectable.h>
#include <Pt/NonCopyable.h>
#include <Pt/Signal.h>
#include <string>
#include <cstddef>
#include <iosfwd>
 
namespace Pt {
 
namespace System {
class EventLoop;
}
 
namespace Http {
 
class Connection;
class Channel;

class PT_HTTP_API Stream : public Connectable
                         , private NonCopyable
{
    friend class Connection;
    friend class Channel;
 
    public:
        ~Stream();

        bool isValid() const
        { return _connection != 0; }

        Channel* channel() const
        { return _channel; }

        const std::string& protocol() const
        { return _protocolName; }

        void close();

        std::streambuf* buffer();

        void beginInput();

        std::size_t endInput();

        void beginOutput();

        std::size_t endOutput();

        void cancel();

        void setTimeout(std::size_t ms);

        System::EventLoop* loop() const;

        Signal<>& inputReady()
        { return _inputReady; }

        Signal<>& outputReady()
        { return _outputReady; }
 
    protected:
        Stream(Connection& connection, const std::string& protocol);
 
        void attachChannel(Channel& channel);
 
        void detachChannel(Channel& channel);
 
    private:
        Connection* _connection;
        Channel* _channel;
        std::string _protocolName;
        Signal<> _inputReady;
        Signal<> _outputReady;
};
 
} // namespace Http
 
} // namespace Pt
 
#endif // PT_HTTP_STREAM_H