decl_stream.hpp

#pragma once
 
#include "../../global.hpp"
 
#include "../../image.hpp"
 
#include "../chunk_image_buffer_description.hpp"
#include "../_decl/decl_stream_base.hpp"
#include "../gevserver.hpp"
 
namespace Cvb
{
  CVB_BEGIN_INLINE_NS
  namespace GevServer
  {

    class Stream : public StreamBase, std::enable_shared_from_this<Stream>
    {
    public:
      explicit Stream(const ServerBasePtr &parent)
            : StreamBase(parent)
      {
      }

      void Send(const ImagePtr &image, std::function<void(const ImagePtr &)> imageReleased);

      bool TrySend(const ImagePtr &image, std::function<void(const ImagePtr &)> imageReleased);

      void Send(const Image &image);

      bool TrySend(const Image &image);

      void Send(const ImageBufferDescription &bufferDescription, void *basePtr, const std::size_t &bufferSize,
                std::function<void(void *)> bufferReleased);

      bool TrySend(const ImageBufferDescription &bufferDescription, void *basePtr, const std::size_t &bufferSize,
                   std::function<void(void *)> bufferReleased);
 
    private:
    
      CExports::cvbres_t InnerSend(const ImagePtr &image, std::function<void(const ImagePtr &)> callback);
 
      CExports::cvbres_t InnerSend(const Image &image);
 
      CExports::cvbres_t InnerSend(const ImageBufferDescription &description, void *basePtr, std::size_t bufferSize,
                                   std::function<void(void *)> callback);
 
      CExports::cvbres_t InnerSend(const ChunkImageBufferDescription &description, void *basePtr,
                                   std::size_t bufferSize, std::function<void(void *)> callback);
    };
  }  // namespace GevServer
  CVB_END_INLINE_NS
}  // namespace Cvb