Description

Contributors

Work Started

Work Submitted

Work Paid

All Activity

Funder

Funder :

Email :

Use ConcurrentMapQueue in Application layer

usetech-llc

C++, C

File: src/application.cpp
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.