103 lines
3.7 KiB
C++
Executable file
103 lines
3.7 KiB
C++
Executable file
#pragma once
|
|
#include <fc/utility.hpp>
|
|
#include <fc/string.hpp>
|
|
#include <memory>
|
|
|
|
namespace fc {
|
|
|
|
/**
|
|
* Provides a fc::thread friendly cooperatively multi-tasked stream that
|
|
* will block 'cooperatively' instead of hard blocking.
|
|
*/
|
|
class istream
|
|
{
|
|
public:
|
|
virtual ~istream(){};
|
|
|
|
/** read at least 1 byte or throw, if no data is available
|
|
* this method should block cooperatively until data is
|
|
* available or fc::eof is thrown.
|
|
*
|
|
* @throws fc::eof if at least 1 byte cannot be read
|
|
**/
|
|
virtual size_t readsome( char* buf, size_t len ) = 0;
|
|
virtual size_t readsome( const std::shared_ptr<char>& buf, size_t len, size_t offset ) = 0;
|
|
|
|
/** read len bytes or throw, this method is implemented
|
|
* in terms of readsome.
|
|
*
|
|
* @throws fc::eof_exception if len bytes cannot be read
|
|
**/
|
|
istream& read( char* buf, size_t len );
|
|
istream& read( const std::shared_ptr<char>& buf, size_t len, size_t offset = 0 );
|
|
virtual char get();
|
|
void get( char& c ) { c = get(); }
|
|
};
|
|
typedef std::shared_ptr<istream> istream_ptr;
|
|
|
|
/**
|
|
* Provides a fc::thread friendly cooperatively multi-tasked stream that
|
|
* will block 'cooperatively' instead of hard blocking.
|
|
*/
|
|
class ostream
|
|
{
|
|
public:
|
|
virtual ~ostream(){};
|
|
virtual size_t writesome( const char* buf, size_t len ) = 0;
|
|
virtual size_t writesome( const std::shared_ptr<const char>& buf, size_t len, size_t offset ) = 0;
|
|
virtual void close() = 0;
|
|
virtual void flush() = 0;
|
|
|
|
void put( char c ) { write(&c,1); }
|
|
|
|
/** implemented in terms of writesome, guarantees len bytes are sent
|
|
* but not flushed.
|
|
**/
|
|
ostream& write( const char* buf, size_t len );
|
|
ostream& write( const std::shared_ptr<const char>& buf, size_t len, size_t offset = 0 );
|
|
};
|
|
|
|
typedef std::shared_ptr<ostream> ostream_ptr;
|
|
|
|
class iostream : public virtual ostream, public virtual istream {};
|
|
|
|
fc::istream& getline( fc::istream&, fc::string&, char delim = '\n' );
|
|
|
|
template<size_t N>
|
|
ostream& operator<<( ostream& o, char (&array)[N] )
|
|
{
|
|
return o.write( array, N );
|
|
}
|
|
|
|
ostream& operator<<( ostream& o, char );
|
|
ostream& operator<<( ostream& o, const char* v );
|
|
ostream& operator<<( ostream& o, const std::string& v );
|
|
ostream& operator<<( ostream& o, const fc::string& v );
|
|
ostream& operator<<( ostream& o, const double& v );
|
|
ostream& operator<<( ostream& o, const float& v );
|
|
ostream& operator<<( ostream& o, const int64_t& v );
|
|
ostream& operator<<( ostream& o, const uint64_t& v );
|
|
ostream& operator<<( ostream& o, const int32_t& v );
|
|
ostream& operator<<( ostream& o, const uint32_t& v );
|
|
ostream& operator<<( ostream& o, const int16_t& v );
|
|
ostream& operator<<( ostream& o, const uint16_t& v );
|
|
ostream& operator<<( ostream& o, const int8_t& v );
|
|
ostream& operator<<( ostream& o, const uint8_t& v );
|
|
#ifndef _MSC_VER
|
|
ostream& operator<<( ostream& o, const size_t& v );
|
|
#endif
|
|
|
|
istream& operator>>( istream& o, std::string& v );
|
|
istream& operator>>( istream& o, fc::string& v );
|
|
istream& operator>>( istream& o, char& v );
|
|
istream& operator>>( istream& o, double& v );
|
|
istream& operator>>( istream& o, float& v );
|
|
istream& operator>>( istream& o, int64_t& v );
|
|
istream& operator>>( istream& o, uint64_t& v );
|
|
istream& operator>>( istream& o, int32_t& v );
|
|
istream& operator>>( istream& o, uint32_t& v );
|
|
istream& operator>>( istream& o, int16_t& v );
|
|
istream& operator>>( istream& o, uint16_t& v );
|
|
istream& operator>>( istream& o, int8_t& v );
|
|
istream& operator>>( istream& o, uint8_t& v );
|
|
}
|