From 5d7ecce6d7906fc8767ceb60a64898443a9344ba Mon Sep 17 00:00:00 2001
From: Collin Smith <collinsmith70@gmail.com>
Date: Sun, 29 Dec 2019 01:54:28 -0800
Subject: [PATCH] Changed from IteratingSystem to BaseEntitySystem

---
 .../riiablo/server/d2gs/NetworkSynchronizer.java    | 13 +++++++++++--
 1 file changed, 11 insertions(+), 2 deletions(-)

diff --git a/server/d2gs/src/com/riiablo/server/d2gs/NetworkSynchronizer.java b/server/d2gs/src/com/riiablo/server/d2gs/NetworkSynchronizer.java
index e97bdc26..c858ceca 100644
--- a/server/d2gs/src/com/riiablo/server/d2gs/NetworkSynchronizer.java
+++ b/server/d2gs/src/com/riiablo/server/d2gs/NetworkSynchronizer.java
@@ -2,9 +2,10 @@ package com.riiablo.server.d2gs;
 
 import com.google.flatbuffers.FlatBufferBuilder;
 
+import com.artemis.BaseEntitySystem;
 import com.artemis.annotations.All;
 import com.artemis.annotations.Wire;
-import com.artemis.systems.IteratingSystem;
+import com.artemis.utils.IntBag;
 import com.badlogic.gdx.Gdx;
 import com.badlogic.gdx.utils.IntIntMap;
 import com.riiablo.engine.server.SerializationManager;
@@ -16,7 +17,7 @@ import java.nio.ByteBuffer;
 import java.util.concurrent.BlockingQueue;
 
 @All(Networked.class)
-public class NetworkSynchronizer extends IteratingSystem {
+public class NetworkSynchronizer extends BaseEntitySystem {
   private static final String TAG = "NetworkSynchronizer";
 
   protected SerializationManager serializer;
@@ -33,6 +34,14 @@ public class NetworkSynchronizer extends IteratingSystem {
   }
 
   @Override
+  protected void processSystem() {
+    IntBag entities = subscription.getEntities();
+    int[] entityIds = entities.getData();
+    for (int i = 0, s = entities.size(); i < s; i++) {
+      process(entityIds[i]);
+    }
+  }
+
   protected void process(int entityId) {
     ByteBuffer sync = sync(entityId);
     int id = players.findKey(entityId, -1);