TokenBuffer.h

Go to the documentation of this file.

/*
 * This file is part of KnowRob, please consult
 * https://github.com/knowrob/knowrob for license details.
 */
 
#ifndef KNOWROB_TOKEN_BUFFER_H
#define KNOWROB_TOKEN_BUFFER_H
 
#include "TokenBroadcaster.h"
#include "TokenQueue.h"
 
namespace knowrob {
    class TokenBuffer : public TokenBroadcaster {
    public:
        TokenBuffer();
 
        void stopBuffering();
 
        std::shared_ptr<TokenQueue> createQueue();
 
    protected:
        std::mutex bufferMutex_;
        std::atomic<bool> isBuffering_;
        std::list<TokenPtr> buffer_;
 
        // Override QueryResultStream
        void push(const TokenPtr &tok) override;
    };
 
    using TokenBufferPtr = std::shared_ptr<TokenBuffer>;
 
} // knowrob
 
#endif //KNOWROB_TOKEN_BUFFER_H