Stagger entity creation

yusijs · Feb 20, 2024 · d0e605d · d0e605d
1 parent 19944c9
commit d0e605d
Showing 1 changed file with 26 additions and 2 deletions.
diff --git a/entities/create-entities-mqtt.ts b/entities/create-entities-mqtt.ts
@@ -15,7 +15,8 @@ export const createEntitiesMqtt = async () => {
  all: true,
  },
  });
- newFeatures.forEach((d) => {
+ for await (const { value: d, done } of staggerEntities(newFeatures)) {
+ if (done) break;
  const homelyDevice = d.device!.toJSON();
  const device = {
  ids: [homelyDevice.id],
@@ -71,5 +72,28 @@ export const createEntitiesMqtt = async () => {
  }
  }
  );
- });
+ }
 };
+
+type ReturnStagger<T> =
+ | {
+ value: T;
+ done: false;
+ }
+ | {
+ value: null;
+ done: true;
+ };
+
+async function* staggerEntities<T>(
+ entities: Array<T>
+): AsyncIterable<ReturnStagger<T>> {
+ for (const entity of entities) {
+ yield { value: entity, done: false };
+ await new Promise<void>((r) => setTimeout(() => r(), 500));
+ }
+ yield {
+ value: null,
+ done: true,
+ };
+}