src/graph/example/WordParser.h

#ifndef HT_EXAMPLE_WORD_PARSER_
#define HT_EXAMPLE_WORD_PARSER_

#include <graph/example/FileReader.h>
#include <graph/NodeBase.h>
#include <options/Config.h>
#include <string>

#define MONONODE(T)                                                     \
        public:                                                         \
            virtual void configured() const {                           \
                if (!next_)                                             \
                    throw ht::options::ConfigError("No follow-on node for node " + name()); \
            }                                                           \
            void connect(Node *n)                                       \
            {                                                           \
                next_ = dynamic_cast<T *>(n);                           \
            }                                                           \
            void disconnect(Node *n) {                                  \
                if (n == next_)                                         \
                    next_ = 0;                                          \
            }                                                           \
        private:                                                        \
            T *next_
        

namespace ht {
    namespace example {

        struct WordBuffer
        {
            size_t row;
            size_t col;
            const char * word;
            size_t length;
            bool isWS;
            WordBuffer() : row(1), col(1), word(0), length(0), isWS(false) {}
        };

        class WordReader : public ht::graph::NodeBase
        {
        public:
            virtual void process(const WordBuffer & buf) = 0;
        };

        class WordParser : public BlockReader
        {
            MONONODE(WordReader);
            WordBuffer word_;
            std::string partial_;
            void sendWord(const char *p, size_t len);
        public:
            WordParser() : next_(0) {}
            virtual void process(const ByteBuffer & buf);
            virtual void stop();
        };
    }
}


#endif

---