Queue class — why is it required? about coin-hive-stratum

[cazala]

When there's a new ws connection, a new tcp connection is created to the pool. While that connection is being created, messages might start to arrive from the ws (like login message) and the tcp connection might not be ready yet. The queue ensures those messages are sent to the pool once the tcp connection is up

[elmigranto]

It seems that delay stays even after connection is established. So even after we opened a socket, message rate is still limited to 1 message per client per second.

[cazala]

Yes, it's not the best solution. Once the connection is up we should just pipe the messages from one socket to the other without the queue in the middle

[cazala]

@elmigranto I tweaked the queue so after the connection is stablished and the queue is cleared, the new messages get emitted right away instead of being queued and emitted every 1 sec: