An asynchronous buffer that converts an IInputStream to IOutputStream (and otherwise). More...

Public Member Functions#
void	write (const char *src, size_t size) override
	Writes exact `size` bytes to stream. Blocking (waiting for write all data) is allowed.

size_t	read (char *dst, size_t size) override
	Reads up to `size` bytes from stream. Blocking (waiting for new data) is allowed.

bool	empty () const noexcept

Public Member Functions inherited from IInputStream
size_t	read (std::span< std::byte > destination)
	Reads up to `destination.size()` bytes from stream. Blocking (waiting for new data) is allowed.

void	readExact (char *dst, size_t size)
	Reads exact `size` bytes from stream. Blocking (waiting for new data) is allowed.

template<typename T>
T	deserialize ()

template<typename T>
IInputStream &	operator>> (T &dst)

template<typename T>
IInputStream &	operator>> (T &&dst)

Public Member Functions inherited from IOutputStream
template<typename T>
void	write (const T &t)

template<typename T>
IOutputStream &	operator<< (const T &t)

Detailed Description#

ADynamicPipe is similar to the unix pipes. It's slower than APipe but it's capable to store any byte count.

Unlike APipe, ADynamicPipe never blocks the thread which can be useful in an asynchronous system.

Member Function Documentation#

size_t ADynamicPipe::read	(	char *	dst,
		size_t	size )

overridevirtual

Sneaky exceptions: An implementation can throw any exception that subclasses AIOException.

Parameters

dst	destination buffer
size	destination buffer's size. > 0

void ADynamicPipe::write	(	const char *	src,
		size_t	size )

overridevirtual

Sneaky exceptions: An implementation can throw any exception that subclasses AIOException.

Parameters

src	source buffer
size	source buffer's size. > 0

Contents