[ROOT] / doc / toc / ARCCore / Class / StreamProcessor / ReceiveAndDistribute

Process all messages in receive queue.
1) Adds the given message to the receive queue and
2) Empties the receive queue asynchronously.
3) Send data to OutsideLocalReceiver (if defined).
4) Feed connections asynchronously with new data (including connections catching up with others).
Emptying queue and feeding connections is done by ensuring that there is a thread running that continously processes messages until the queue is empty / all connections are fed (not how this thread exists as soon as the queue is empty)

TODO: At initialization, All logging destined for the property stream done BEFORE an Outgoing Send connection has been established, TODO: will most probably be lost.TODO: Implement some form of queue or similar, until connection have been established.

Generated 2024-12-22 06:12:51.444 UTC