Check out the Issue Explorer
Looking to fund some work? You can submit a new Funded Issue here.
CPolkaApi::handleWsMessage should call ConcurrentMapQueue::put method with key = subscriptionId and value = message.
CPolkaApi::subscribe... methods should start a thread that calls ConcurrentMapQueue::get with matching subscription ID and calls the matching callback like it is currently done in CPolkaApi::handleWsMessage, when it receives message from concurrent queue.