Abstraction of the transformation source module. More...
#include <transform-base.hpp>
Public Member Functions | |
Source & | operator>> (unique_ptr< Transform > transform) |
Connect to an intermediate transformation module. More... | |
void | operator>> (unique_ptr< Sink > sink) |
Connect to the last transformation module. More... | |
Public Member Functions inherited from ndn::security::transform::Upstream | |
virtual | ~Upstream ()=default |
Protected Member Functions | |
Source () | |
void | pump () |
Pump all data into next transformation module. More... | |
size_t | getIndex () const |
Get the source module index (should always be 0). More... | |
Protected Member Functions inherited from ndn::security::transform::Upstream | |
Upstream () | |
void | appendChain (unique_ptr< Downstream > tail) |
connect to next transformation module More... | |
Downstream * | getNext () |
Additional Inherited Members | |
Protected Attributes inherited from ndn::security::transform::Upstream | |
unique_ptr< Downstream > | m_next |
Abstraction of the transformation source module.
This module can only accept input data from constructor
Definition at line 288 of file transform-base.hpp.
|
protected |
Definition at line 154 of file transform-base.cpp.
Connect to an intermediate transformation module.
Definition at line 166 of file transform-base.cpp.
References ndn::security::transform::Upstream::appendChain().
void ndn::security::transform::Source::operator>> | ( | unique_ptr< Sink > | sink | ) |
Connect to the last transformation module.
This method will trigger the source to pump data into the transformation pipeline.
Definition at line 176 of file transform-base.cpp.
References ndn::security::transform::Upstream::appendChain(), and pump().
|
protected |
Pump all data into next transformation module.
Definition at line 160 of file transform-base.cpp.
Referenced by operator>>().
|
inlineprotected |
Get the source module index (should always be 0).
Definition at line 319 of file transform-base.hpp.
Referenced by ndn::security::transform::StreamSource::StreamSource().