refactor: improve " $$flush" fn

Author: tonyfromundefined

src/Entity.ts

@@ -291,7 +291,10 @@ export function Entity<$$Schema extends DefaultSchema>(
     }
 
     " $$flush"() {
+      const queuedEvents = [...this[" $$queuedEvents"]];
       this[" $$queuedEvents"] = [];
+
+      return queuedEvents;
     }
 
     " $$createEvent"<EventName extends InferEventNameFromSchema<$$Schema>>(

src/createRepository.ts

@@ -168,7 +168,7 @@ export function createRepository<
       const _entity = entity as Entity<$$Schema>;
 
       // 1. copy queued events
-      const queuedEvents = [..._entity[" $$queuedEvents"]];
+      const queuedEvents = _entity[" $$flush"]();
 
       // 2. commit events to adapter
       await args.adapter.commitEvents({
@@ -178,10 +178,7 @@ export function createRepository<
         state: _entity.state,
       });
 
-      // 3. flush queued events
-      _entity[" $$flush"]();
-
-      // 4. run plugins in parallel (only if there are events)
+      // 3. run plugins in parallel (only if there are events)
       if (args.plugins && args.plugins.length > 0 && queuedEvents.length > 0) {
         const pluginResults = await Promise.allSettled(
           args.plugins.map((plugin) =>

src/types/Entity.ts

@@ -110,7 +110,7 @@ export interface Entity<$$Schema> {
   ) => void;
 
   /** @internal */
-  " $$flush": () => void;
+  " $$flush": () => InferEventFromSchema<$$Schema>[];
 
   /** @internal */
   " $$createEvent": <EventName extends InferEventNameFromSchema<$$Schema>>(