@@ -295,14 +295,11 @@ export class ControllerMessageHandler implements MessageHandler {
295295 await this . driver . controller . restoreNVMRaw (
296296 nvmData ,
297297 ( bytesWritten : number , total : number ) => {
298- this . clientsController . clients . forEach ( ( client ) => {
299- if ( ! client . isConnected || ! client . receiveEvents ) return ;
300- client . sendEvent ( {
301- source : "controller" ,
302- event : "nvm restore progress" ,
303- bytesWritten,
304- total,
305- } ) ;
298+ this . clientsController . sendEventToListeningClients ( {
299+ source : "controller" ,
300+ event : "nvm restore progress" ,
301+ bytesWritten,
302+ total,
306303 } ) ;
307304 } ,
308305 ) ;
@@ -628,25 +625,23 @@ export class ControllerMessageHandler implements MessageHandler {
628625 strategy : message . strategy ?? JoinNetworkStrategy . Default ,
629626 userCallbacks : {
630627 showDSK : ( dsk : string ) => {
631- this . clientsController . clients . forEach ( ( client ) => {
632- if ( ! client . isConnected || ! client . receiveEvents ) return ;
633- if ( client . schemaVersion < 47 ) return ;
634- client . sendEvent ( {
628+ this . clientsController . sendEventToListeningClients (
629+ {
635630 source : "controller" ,
636631 event : "joining network show dsk" ,
637632 dsk,
638- } ) ;
639- } ) ;
633+ } ,
634+ { minSchemaVersion : 47 } ,
635+ ) ;
640636 } ,
641637 done : ( ) => {
642- this . clientsController . clients . forEach ( ( client ) => {
643- if ( ! client . isConnected || ! client . receiveEvents ) return ;
644- if ( client . schemaVersion < 47 ) return ;
645- client . sendEvent ( {
638+ this . clientsController . sendEventToListeningClients (
639+ {
646640 source : "controller" ,
647641 event : "joining network done" ,
648- } ) ;
649- } ) ;
642+ } ,
643+ { minSchemaVersion : 47 } ,
644+ ) ;
650645 } ,
651646 } ,
652647 } ) ;
0 commit comments