scclib
Stable Cloud Computing C++ Library
Public Member Functions | List of all members
scc::util::InPipeline Struct Reference

Input stream with pipeline of readers. More...

#include <iopipeline.h>

Inheritance diagram for scc::util::InPipeline:
Inheritance graph
[legend]
Collaboration diagram for scc::util::InPipeline:
Collaboration graph
[legend]

Public Member Functions

 InPipeline (const std::shared_ptr< Reader > &, size_t=1024)
 Create with base reader and read buffer size.
 
std::shared_ptr< Readerrd_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.
 
InStreamoperator= (const InStream &)=delete
 Copy assign not allowed.
 
 InStream (InStream &&)
 Move construct.
 
InStreamoperator= (InStream &&)
 Move assign.
 
void read_reset (const std::shared_ptr< Reader > &)
 
std::shared_ptr< Readerread_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< Readerrd_base
 
std::list< std::shared_ptr< PipelineReader > > rd_chain
 

Detailed Description

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.


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