
21 May
2020
21 May
'20
6:59 a.m.
Maybe fork another thread, keep reading data and putting into a shared `MVar` / `TMVar`, then current thread keep taking from that var?
The code already use async in order to read only a chunk of the data. But is true, that I could have a thread whcih read the data and post the messag into a queue. then workers take these frames and produce a monoid. then all monoid are reduced into the final one.