LibCore: Simplify how we calculate processed event count

awesomekling · awesomekling · commit 05e449d32a8f · 2025-12-03T13:26:27.000+01:00
diff --git a/Libraries/LibCore/ThreadEventQueue.cpp b/Libraries/LibCore/ThreadEventQueue.cpp
@@ -114,7 +114,6 @@ size_t ThreadEventQueue::process()
         m_private->pending_promises.remove_all_matching([](auto& job) { return job->is_resolved() || job->is_rejected(); });
     }
 
-    size_t processed_events = 0;
     for (auto& queued_event : events) {
         if (auto receiver = queued_event.receiver.strong_ref()) {
             switch (queued_event.event_type) {
@@ -138,10 +137,9 @@ size_t ThreadEventQueue::process()
                 // Receiver gone, drop the event.
             }
         }
-        ++processed_events;
     }
 
-    return processed_events;
+    return events.size();
 }
 
 bool ThreadEventQueue::has_pending_events() const

Original file line number	Diff line number	Diff line change
`@@ -114,7 +114,6 @@ size_t ThreadEventQueue::process()`
`114`	`114`	`m_private->pending_promises.remove_all_matching([](auto& job) { return job->is_resolved() \|\| job->is_rejected(); });`
`115`	`115`	`}`
`116`	`116`
`117`		`- size_t processed_events = 0;`
`118`	`117`	`for (auto& queued_event : events) {`
`119`	`118`	`if (auto receiver = queued_event.receiver.strong_ref()) {`
`120`	`119`	`switch (queued_event.event_type) {`
`@@ -138,10 +137,9 @@ size_t ThreadEventQueue::process()`
`138`	`137`	`// Receiver gone, drop the event.`
`139`	`138`	`}`
`140`	`139`	`}`
`141`		`- ++processed_events;`
`142`	`140`	`}`
`143`	`141`
`144`		`- return processed_events;`
	`142`	`+ return events.size();`
`145`	`143`	`}`
`146`	`144`
`147`	`145`	`bool ThreadEventQueue::has_pending_events() const`