Stream.Pipe.hpp

Go to the documentation of this file.

//
//  CeresEngine - A game development framework
//
//  Created by Rogiel Sulzbach.
//  Copyright (c) 2018-2022 Rogiel Sulzbach. All rights reserved.
//
 
#pragma once
 
#include "Stream.hpp"
 
namespace CeresEngine {
 
    class PipeStream : public virtual IStream {
    protected:
        struct State;
 
        SPtr<State> mState;
 
    private:
        explicit PipeStream(SPtr<State> state);
 
    public:
        PipeStream(const PipeStream&) = delete;
        PipeStream& operator=(const PipeStream&) = delete;
 
        PipeStream(PipeStream&&) noexcept;
        PipeStream& operator=(PipeStream&&) noexcept = delete;
 
    public:
        static Pair<InputStream, OutputStream> open();
 
    public: // IStream interface
        [[nodiscard]] bool isSeekable(Seek mode = Seek::Start) const noexcept final { return false; }
 
        [[nodiscard]] bool isTellable() const noexcept final { return false; }
 
        [[nodiscard]] bool isSizeKnown() const noexcept final { return false; }
    };
 
    CE_DISABLE_WARNING_PUSH
    CE_DISABLE_WARNING_INHERITS_VIA_DOMINANCE
 
    class PipeInputStream : public virtual PipeStream, public IInputStream {
    public:
        using PipeStream::PipeStream;
        PipeInputStream(PipeInputStream&&) noexcept = default;
        ~PipeInputStream() noexcept;
 
    public: // IInputStream interface
        [[nodiscard]] bool isReadable() const noexcept final { return true; }
 
        [[nodiscard]] size_t read(void* data, size_t n) final;
 
        using PipeStream::isSeekable;
        using PipeStream::isTellable;
        using PipeStream::isSizeKnown;
    };
 
    class PipeOutputStream : public virtual PipeStream, public IOutputStream {
    public:
        using PipeStream::PipeStream;
        PipeOutputStream(PipeOutputStream&&) noexcept = default;
        ~PipeOutputStream() noexcept;
 
 
    public:  // IOutputStream interface
        [[nodiscard]] bool isWritable() const noexcept final { return true; }
 
        [[nodiscard]] size_t write(const void* data, size_t n) final;
 
        using PipeStream::isSeekable;
        using PipeStream::isTellable;
        using PipeStream::isSizeKnown;
    };
    CE_DISABLE_WARNING_POP
} // namespace CeresEngine