Rate Limit Funktionsaufrufe in Typescript

Question

Update: Ich weiß jetzt, dass Drossel überschüssige Funktionsaufrufe fallen lassen wird, so ist es nicht das richtige Werkzeug. Ich würde immer noch eine idiomatische Art und Weise mögen, alle Gegenstände in einer Schlange zu bearbeiten, ohne zu schnell zu gehen oder irgendwelche Gegenstände fallen zu lassen.

---

Ich schreibe eine Knoten-App, die eine API mit einem Ratenlimit trifft. Ich kann Anrufe viel schneller erstellen, als ich ihnen senden darf. Ich möchte eine Warteschlange von Anrufen konsumieren, aber ohne zu schnell zu gehen oder irgendwelche von ihnen fallen zu lassen. Ich machte einen kleinen Typescript Test meine Probleme zu veranschaulichen:

import * as _ from "lodash"; 

let start = new Date().getTime(); 

function doLog(s: string) { 
    let elapsed = new Date().getTime() - start; 
    console.log(`${s} ${elapsed}`); 
} 

let array = ['a', 'b', 'c', 'd', 'e', 'f', 'g', 'h', 'i', 'j']; 
let throttled = _.throttle(doLog, 100); 
array.forEach(s => throttled(s)); 

Ich erwartete Ausgabe zu sehen, etwa wie:

a 2 
b 101 
c 203 
d 302 
e 405 
f 502 
g 603 
h 706 
i 804 
j 902 

Aber stattdessen sehe ich:

a 2 
j 101 

einige merkwürdige Beobachtungen I‘ ve made:

• Bei 100ms Drossel, die si ze des Arrays scheint irrelevant: Ich werde das erste und letzte Element im Array drucken, ob es 2 Elemente oder 20 hat.
• Bei 1ms Drossel, drucke ich 3-6 Elemente von der Vorderseite des Arrays, und die letzte Element

Answer 1

Wenn Sie nicht kümmern uns um doLog() sicher ist „fertig“, bevor der nächste Aufruf ein, können Sie setTimeout

let array = ['a', 'b', 'c', 'd', 'e', 'f', 'g', 'h', 'i', 'j']; 
array.forEach((s, i) => setTimeout(doLog, i*100, s)); 

Adam verwenden nur eine gute Erklärung gibt, warum throttle in diesem cas ist nicht gut e.

Answer 2

Wenn eine gedrosselte Funktion mehr als einmal während der Wartezeit aufgerufen wird, werden nachfolgende Aufrufe ignoriert. Wenn Sie jedes Element in einem Array verarbeiten müssen, ist throttle() wahrscheinlich nicht das, was Sie wollen. Es ist besser geeignet, um beispielsweise übermäßige Aktualisierungen in der Benutzeroberfläche zu verhindern.

Der Grund, warum Sie immer a und j in Ihrer Ausgabe sehen, liegt an Vorder- und Hinterkanten. Das gesamte Array wurde in weniger als 100 ms verarbeitet. Da jedoch der Standardwert für "Vorlauf" und "Nachlauf" auf "Wahr" gesetzt ist, werden beide Aufrufe angezeigt (der erste und der letzte Aufruf der gedrosselten Funktion).

Answer 3

Wenn Sie bereit sein würde RxJS zu verwenden, würde diese Antwort können Sie dies erreichen ziemlich idiomatisch:

https://stackoverflow.com/a/31855054/553003