mframe/src/ufm/io/InputBuffer.h

 
#ifndef MFRAME_58654FF5_B5E0_425E_B939_1652199624DC
#define MFRAME_58654FF5_B5E0_425E_B939_1652199624DC
 
/* ***************************************************************************************
 * Include
 */
 
//----------------------------------------------------------------------------------------
#include "./../io/InputStream.h"
#include "./../io/RingBuffer.h"
#include "./../lang/Object.h"
#include "./../lang/Updatable.h"
 
//----------------------------------------------------------------------------------------
 
/* ***************************************************************************************
 * Namespace
 */
namespace ufm::io {
  class InputBuffer;
}  // namespace ufm::io
 
/* ***************************************************************************************
 * Class/Interface/Struct/Enum
 */
 
class ufm::io::InputBuffer : public ufm::lang::Object,
                             public ufm::io::CompletionHandler<int>,
                             public ufm::lang::Updatable {
  /* *************************************************************************************
   * Variable
   */
 private:
  ufm::io::InputStream& vInputStream;
  ufm::io::RingBuffer   vRingBuffer;
  bool                  vBusy;
 
  /* *************************************************************************************
   * Abstract Method
   */
 
  /* *************************************************************************************
   * Construct Method
   */
 public:
  InputBuffer(ufm::io::InputStream& inputStream, ufm::lang::Memory buffer) noexcept;
 
  virtual ~InputBuffer(void) override;
 
  /* *************************************************************************************
   * Operator Method
   */
 public:
  inline operator ufm::lang::Readable&(void) {
    return this->vRingBuffer;
  }
 
  /* *************************************************************************************
   * Override - ufm::io::CompletionHandler<int>
   */
 public:
  virtual void completed(int& result, void* attachment) override;
 
  virtual void failed(void* attachment) override;
 
  /* *************************************************************************************
   * Override - ufm::lang::Updatable
   */
 public:
  virtual void update(void) override;
 
  /* *************************************************************************************
   * Public Method
   */
 
  /* *************************************************************************************
   * Protected Method
   */
 
  /* *************************************************************************************
   * Private Method
   */
 
  /* *************************************************************************************
   * Static Variable
   */
 
  /* *************************************************************************************
   * Static Method
   */
};
 
/* ***************************************************************************************
 * End of file
 */
 
#endif /* MFRAME_58654FF5_B5E0_425E_B939_1652199624DC */