Code

Implement ordered concurrency#31

Code

Open

flying-scorpio wants to merge 8 commits intoverdigado:mainverdigado/rocketchat2matrix:mainfrom flying-scorpio:ordered-concurrencyflying-scorpio/rocketchat2matrix:ordered-concurrencyCopy head branch name to clipboard

+72-18

Commits

Commits on Jul 26, 2024

• Use PromisePool to add concurrency to users and rooms

  flying-scorpio

  committed
  2aa2626

  Copy full SHA for 2aa2626

• Use a Map to assign messages to their corresponding room for processing

  flying-scorpio

  committed
  c19a9ad

  Copy full SHA for c19a9ad

• Add types for the processing queues

  flying-scorpio

  committed
  15cda97

  Copy full SHA for 15cda97

Commits on Jul 29, 2024

• Use camelCase for new variables

  flying-scorpio

  committed
  78948bc

  Copy full SHA for 78948bc

Commits on Jul 30, 2024

• Move switch out of while loop, add loops for each case

  flying-scorpio

  committed
  9fa8e03

  Copy full SHA for 9fa8e03

• Move PromisePools inside each case

  flying-scorpio

  committed
  64935fd

  Copy full SHA for 64935fd

• Wrap lineByLine in iterator to remove queues

  flying-scorpio

  committed
  7a7fdec

  Copy full SHA for 7a7fdec

Commits on Aug 15, 2024

• Handle messages in batches to avoid OOM kill

  flying-scorpio

  committed
  bee1c2f

  Copy full SHA for bee1c2f