#include "rediska/worker/AsyncWorker.hpp"
#include "rediska/frontend/server.hpp"
#include <iostream>

int run_async_server() {
    rediska::worker::AsyncWorker worker(4, 1000);
    worker.Start();
    
    RunFrontendServer("0.0.0.0:50051", [&worker](QueueMessage msg) {
        worker.Enqueue(std::move(msg));
    });
    
    return 0;
}