A source that can accept input step by step, and can close input explicitly. More...
#include <step-source.hpp>
Public Member Functions | |
void | end () |
Close the input interface and directly notify the next module the end of input. More... | |
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... | |
size_t | write (const uint8_t *buf, size_t size) |
Accept input data and directly write input into next transformation module. More... | |
Protected Member Functions | |
void | appendChain (unique_ptr< Downstream > tail) |
connect to next transformation module More... | |
size_t | getIndex () const |
Get the source module index (should always be 0). More... | |
Downstream * | getNext () |
void | pump () |
Pump all data into next transformation module. More... | |
Protected Attributes | |
unique_ptr< Downstream > | m_next |
A source that can accept input step by step, and can close input explicitly.
This source will not send data into the transformation chain when the chain is constructed. Input will be explicitly sent into the chain using write(...) and will be closed explicitly using end().
StepSource ss; ss >> transform1() >> transform2() >> sinkStream(...); ss.write(...); ... ss.write(...); ss.end();
Definition at line 45 of file step-source.hpp.
|
protectedinherited |
connect to next transformation module
Definition at line 67 of file transform-base.cpp.
void ndn::security::transform::StepSource::end | ( | ) |
Close the input interface and directly notify the next module the end of input.
Definition at line 35 of file step-source.cpp.
|
inlineprotectedinherited |
Get the source module index (should always be 0).
Definition at line 319 of file transform-base.hpp.
|
inlineprotectedinherited |
Definition at line 173 of file transform-base.hpp.
|
inherited |
Connect to an intermediate transformation module.
Definition at line 166 of file transform-base.cpp.
|
inherited |
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.
|
protectedinherited |
Pump all data into next transformation module.
Definition at line 160 of file transform-base.cpp.
size_t ndn::security::transform::StepSource::write | ( | const uint8_t * | buf, |
size_t | size | ||
) |
Accept input data and directly write input into next transformation module.
One can keep calling this method to until end() is called, which indicates the end of input. After that, calling this method will cause Error.
Definition at line 29 of file step-source.cpp.
|
protectedinherited |
Definition at line 179 of file transform-base.hpp.