core::pipe::Sink Class Reference

#include <Sink.h>

Inheritance diagram for core::pipe::Sink:

Collaboration diagram for core::pipe::Sink:

Public Member Functions
	Sink (Sink &)=delete
Sink &	operator= (Sink &)=delete

Protected Member Functions
	Sink ()=default
	Sink (Sink &&) noexcept=default
Sink &	operator= (Sink &&) noexcept=default
virtual	~Sink ()
bool	isStreaming ()
void	stop ()

Private Member Functions
void	pipe (Source *source)
void	streamData (const char *chunk, std::size_t chunkLen)
void	streamEof ()
void	streamError (int errnum)
void	disconnect (const Source *source)
virtual void	onSourceConnect (Source *source)=0
virtual void	onSourceData (const char *chunk, std::size_t chunkLen)=0
virtual void	onSourceEof ()=0
virtual void	onSourceError (int errnum)=0

Private Attributes
Source *	source = nullptr

Friends
class	Source

Detailed Description

Definition at line 35 of file Sink.h.

Constructor & Destructor Documentation

Sink() [1/3]

core::pipe::Sink::Sink ( Sink & )

delete

Sink() [2/3]

core::pipe::Sink::Sink ( )

protecteddefault

Sink() [3/3]

core::pipe::Sink::Sink ( Sink && )

protecteddefaultnoexcept

~Sink()

core::pipe::Sink::~Sink ( )

protectedvirtual

Definition at line 30 of file Sink.cpp.

                {
        if (source != nullptr) {
            source->disconnect(this);
        }
    }

Member Function Documentation

disconnect()

void core::pipe::Sink::disconnect ( const Source * source )

private

Definition at line 64 of file Sink.cpp.

                                              {
        if (source == this->source) {
            this->source = nullptr;
        }
    }

isStreaming()

bool core::pipe::Sink::isStreaming ( )

protected

Definition at line 42 of file Sink.cpp.

                           {
        return source != nullptr;
    }

onSourceConnect()

virtual void core::pipe::Sink::onSourceConnect ( Source * source )

privatepure virtual

Implemented in web::http::client::Request, and web::http::server::Response.

onSourceData()

virtual void core::pipe::Sink::onSourceData ( const char * chunk, std::size_t chunkLen )

privatepure virtual

Implemented in web::http::client::Request, and web::http::server::Response.

onSourceEof()

virtual void core::pipe::Sink::onSourceEof ( )

privatepure virtual

Implemented in web::http::client::Request, and web::http::server::Response.

onSourceError()

virtual void core::pipe::Sink::onSourceError ( int errnum )

privatepure virtual

Implemented in web::http::client::Request, and web::http::server::Response.

operator=() [1/2]

Sink & core::pipe::Sink::operator= ( Sink && )

protecteddefaultnoexcept

operator=() [2/2]

Sink & core::pipe::Sink::operator= ( Sink & )

delete

pipe()

void core::pipe::Sink::pipe ( Source * source )

private

Definition at line 36 of file Sink.cpp.

                                  {
        this->source = source;
 
        onSourceConnect(source);
    }

stop()

void core::pipe::Sink::stop ( )

protected

Definition at line 46 of file Sink.cpp.

                    {
        if (source != nullptr) {
            source->disconnect(this);
        }
    }

streamData()

void core::pipe::Sink::streamData ( const char * chunk, std::size_t chunkLen )

private

Definition at line 52 of file Sink.cpp.

                                                               {
        onSourceData(chunk, chunkLen);
    }

streamEof()

void core::pipe::Sink::streamEof ( )

private

Definition at line 56 of file Sink.cpp.

                         {
        onSourceEof();
    }

streamError()

void core::pipe::Sink::streamError ( int errnum )

private

Definition at line 60 of file Sink.cpp.

                                     {
        onSourceError(errnum);
    }

Friends And Related Symbol Documentation

Source

friend class Source

friend

Definition at line 70 of file Sink.h.

Member Data Documentation

source

Source* core::pipe::Sink::source = nullptr

private

Definition at line 68 of file Sink.h.

---

The documentation for this class was generated from the following files:

• core/pipe/Sink.h
• core/pipe/Sink.cpp