adf
This commit is contained in:
@@ -31,7 +31,7 @@ void InputSocketHandler::run()
|
|||||||
{
|
{
|
||||||
while(true)
|
while(true)
|
||||||
{
|
{
|
||||||
Event event = this->queue->pop();
|
Event event = this->queue.pop();
|
||||||
|
|
||||||
if(event.name == "END")
|
if(event.name == "END")
|
||||||
{
|
{
|
||||||
@@ -49,7 +49,7 @@ void InputSocketHandler::run()
|
|||||||
|
|
||||||
void InputSocketHandler::handle(Event &event)
|
void InputSocketHandler::handle(Event &event)
|
||||||
{
|
{
|
||||||
this->queue->push(event);
|
this->queue.push(event);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -14,7 +14,7 @@
|
|||||||
#include "input/InputDriver.h"
|
#include "input/InputDriver.h"
|
||||||
#include "input/EventHandler.h"
|
#include "input/EventHandler.h"
|
||||||
#include "input/Event.h"
|
#include "input/Event.h"
|
||||||
#include "utility/IBlockingQueue.h"
|
#include "utility/BlockingQueue.hpp"
|
||||||
|
|
||||||
namespace flippR_driver
|
namespace flippR_driver
|
||||||
{
|
{
|
||||||
@@ -32,7 +32,7 @@ public:
|
|||||||
void handle(flippR_driver::input::Event &event) override;
|
void handle(flippR_driver::input::Event &event) override;
|
||||||
|
|
||||||
private:
|
private:
|
||||||
utility::IBlockingQueue<flippR_driver::input::Event>* queue;
|
utility::BlockingQueue<flippR_driver::input::Event> queue;
|
||||||
};
|
};
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user