IOmux.h

#pragma once


#include <libutl/Array.h>
#include <libutl/Stream.h>


UTL_NS_BEGIN;


class IOmux : public Stream
{
    UTL_CLASS_DECL(IOmux, Stream);

public:
    IOmux(uint_t mode, bool owner = true)
    {
        init(mode, owner);
    }

    virtual void close();

    virtual void copy(const Object& rhs);

    bool
    add(const Stream* stream)
    {
        setError(false);
        return _streams.add(stream);
    }

    virtual void checkOK();

    bool remove(const Stream* stream);

    bool setInput(const Stream* stream);

    bool
    isOwner() const
    {
        return _streams.isOwner();
    }

    void
    setOwner(bool owner)
    {
        super::setOwner(owner);
        _streams.setOwner(owner);
    }

    const TArray<Stream>&
    streams() const
    {
        return _streams;
    }

    virtual size_t read(byte_t* array, size_t maxBytes, size_t minBytes = size_t_max);

    virtual void write(const byte_t* array, size_t num);

protected:
    size_t _input;
    TArray<Stream> _streams;

private:
    void init(uint_t mode = io_rdwr, bool owner = true);
    void
    deInit()
    {
    }
};


UTL_NS_END;