Small improvement

boardgameio · Aug 11, 2021 · 0768853 · 0768853
1 parent 650e936
commit 0768853
Showing 1 changed file with 10 additions and 10 deletions.
diff --git a/src/server/transport/socketio.ts b/src/server/transport/socketio.ts
@@ -131,16 +131,16 @@ export class SocketIO {
   }
 
   private subscribePubSubChannel(matchID: string, game: Game) {
-    this.pubSub.subscribe(
-      getPubSubChannelId(matchID),
-      (payload: IntermediateTransportData) => {
-        this.roomInfo.get(matchID).forEach((clientID) => {
-          const client = this.clientInfo.get(clientID);
-          const data = getFilterPlayerView(game)(client.playerID, payload);
-          emit(client.socket, data);
-        });
-      }
-    );
+    const filterPlayerView = getFilterPlayerView(game);
+    const broadcast = (payload: IntermediateTransportData) => {
+      this.roomInfo.get(matchID).forEach((clientID) => {
+        const client = this.clientInfo.get(clientID);
+        const data = filterPlayerView(client.playerID, payload);
+        emit(client.socket, data);
+      });
+    };
+
+    this.pubSub.subscribe(getPubSubChannelId(matchID), broadcast);
   }
 
   private unsubscribePubSubChannel(matchID: string) {