00001 // This file may be redistributed and modified only under the terms of 00002 // the GNU Lesser General Public License (See COPYING for details). 00003 // Copyright (C) 2000 Stefanus Du Toit 00004 00005 #ifndef ATLAS_MESSAGE_QUEUEDDECODER_H 00006 #define ATLAS_MESSAGE_QUEUEDDECODER_H 00007 00008 #include <queue> 00009 #include <Atlas/Message/DecoderBase.h> 00010 00011 namespace Atlas { namespace Message { 00012 00026 class QueuedDecoder : public DecoderBase 00027 { 00028 public: 00029 00030 QueuedDecoder(); 00031 00033 size_t QueueSize(); 00035 Object Pop(); 00037 Object Front(); 00039 void Clear(); 00040 00041 protected: 00042 00044 void ObjectArrived(const Object& obj); 00045 00046 private: 00047 00048 std::queue<Object> objectQueue; 00049 }; 00050 00051 } } // namespace Atlas::Message 00052 00053 #endif
Copyright 2000 the respective authors.
This document is licensed under the terms of the GNU Free Documentation License and may be freely distributed under the conditions given by this license.