InputStream.h

 
#ifndef MFRAME_029349A4_F909_41C7_AC18_0DE3B02FAB01
#define MFRAME_029349A4_F909_41C7_AC18_0DE3B02FAB01
 
/* ***************************************************************************************
 * Include
 */
 
//----------------------------------------------------------------------------------------
 
//----------------------------------------------------------------------------------------
#include "./../io/CompletionHandler.h"
#include "./../lang/Appendable.h"
#include "./../util/Future.h"
 
/* ***************************************************************************************
 * Namespace
 */
namespace mframe::io {
  struct InputStream;
}
 
/* ***************************************************************************************
 * Class/Interface/Struct/Enum
 */
struct mframe::io::InputStream : public virtual mframe::lang::Interface {
  virtual bool abortRead(void) abstract;
 
  virtual bool readBusy(void) abstract;
 
  virtual bool read(mframe::lang::Appendable&           appendable,
                    void*                               attachment,
                    mframe::io::CompletionHandler<int>* handler) abstract;
 
  inline bool read(mframe::lang::Appendable&  appendable,
                   mframe::util::Future<int>& future) {
    if (future.isBusy())
      return false;
 
    future.setWait();
    if (this->read(appendable, nullptr, &future))
      return true;
 
    future.failed(nullptr);
    return false;
  }
};
 
/* ***************************************************************************************
 * End of file
 */
 
#endif /* MFRAME_029349A4_F909_41C7_AC18_0DE3B02FAB01 */