|
scclib
Stable Cloud Computing C++ Library
|
Input stream with pipeline of readers. More...
#include <iopipeline.h>


Public Member Functions | |
| InPipeline (const std::shared_ptr< Reader > &, size_t=1024) | |
| Create with base reader and read buffer size. | |
| std::shared_ptr< Reader > | rd_fix_chain () |
| Fix the chain, and return the pointer that should be pointed to by the stream. | |
Public Member Functions inherited from scc::util::InChain | |
| InChain (const std::shared_ptr< Reader > &) | |
| Create with base reader and read buffer size. More... | |
| void | rd_replace_base (const std::shared_ptr< PipelineReader > &r) |
| Replace the base writer with a new base writer. | |
| void | rd_add_back (const std::shared_ptr< PipelineReader > &r) |
| Add a reader to the end of the chain (before the base). | |
| void | rd_add_front (const std::shared_ptr< PipelineReader > &r) |
| Add a reader to the start of the chain (after the stream). | |
| void | rd_del (const std::shared_ptr< PipelineReader > &) |
| Delete a reader from the chain. | |
Public Member Functions inherited from scc::util::InStream | |
| InStream (Reader &, size_t=1024) | |
| Create reader stream. More... | |
| InStream (const std::shared_ptr< Reader > &, size_t=1024) | |
| Create reader stream. More... | |
| InStream ()=delete | |
| No default construct. | |
| InStream (const InStream &)=delete | |
| Copy construct not allowed. | |
| InStream & | operator= (const InStream &)=delete |
| Copy assign not allowed. | |
| InStream (InStream &&) | |
| Move construct. | |
| InStream & | operator= (InStream &&) |
| Move assign. | |
| void | read_reset (const std::shared_ptr< Reader > &) |
| std::shared_ptr< Reader > | read_shared () const |
| virtual size_t | recvbuf_size () const |
| Size of receive buffer. | |
| virtual void | recvbuf_size (size_t) |
| Resize the receive buffer. More... | |
| virtual std::string | recv_fail () const |
| Failure message from the input stream. More... | |
| void | clear (std::ios::iostate=std::ios::goodbit) |
Additional Inherited Members | |
Public Attributes inherited from scc::util::InChain | |
| std::shared_ptr< Reader > | rd_base |
| std::list< std::shared_ptr< PipelineReader > > | rd_chain |
Input stream with pipeline of readers.
Without: stream reads <-> base With chain: stream reads <-> chain[0] <-> ... <-> chain[N] <-> base
Definition at line 134 of file iopipeline.h.