mirror of
https://github.com/RetroShare/RetroShare.git
synced 2024-12-28 00:49:28 -05:00
36 lines
544 B
C
36 lines
544 B
C
|
#pragma once
|
||
|
|
||
|
#include <list>
|
||
|
|
||
|
#include <serialiser/rsserial.h>
|
||
|
#include <pqi/pqiservice.h>
|
||
|
|
||
|
class FakePublisher: public pqiPublisher
|
||
|
{
|
||
|
public:
|
||
|
virtual bool sendItem(RsRawItem *item)
|
||
|
{
|
||
|
_item_queue.push_back(item) ;
|
||
|
return true;
|
||
|
}
|
||
|
|
||
|
RsRawItem *outgoing()
|
||
|
{
|
||
|
if(_item_queue.empty())
|
||
|
return NULL ;
|
||
|
|
||
|
RsRawItem *item = _item_queue.front() ;
|
||
|
_item_queue.pop_front() ;
|
||
|
return item ;
|
||
|
}
|
||
|
|
||
|
bool outgoingEmpty()
|
||
|
{
|
||
|
return _item_queue.empty();
|
||
|
}
|
||
|
|
||
|
private:
|
||
|
std::list<RsRawItem*> _item_queue ;
|
||
|
};
|
||
|
|