File tree Expand file tree Collapse file tree 4 files changed +7
-7
lines changed
Expand file tree Collapse file tree 4 files changed +7
-7
lines changed Original file line number Diff line number Diff line change 95999599 // Manually emit SubscriptionChanged status event
96009600 this.dependencies.emitStatus({
96019601 category: StatusCategory$1.PNSubscriptionChangedCategory,
9602- affectedChannels: Array.from(new Set(this.channels.filter((c) => !c.endsWith('-pnpres')) )),
9603- affectedChannelGroups: Array.from(new Set(this.groups.filter((g) => !g.endsWith('-pnpres')) )),
9602+ affectedChannels: Array.from(new Set(this.channels)),
9603+ affectedChannelGroups: Array.from(new Set(this.groups)),
96049604 currentTimetoken,
96059605 });
96069606 }
Original file line number Diff line number Diff line change @@ -125,8 +125,8 @@ class EventEngine {
125125 // Manually emit SubscriptionChanged status event
126126 this . dependencies . emitStatus ( {
127127 category : categories_1 . default . PNSubscriptionChangedCategory ,
128- affectedChannels : Array . from ( new Set ( this . channels . filter ( ( c ) => ! c . endsWith ( '-pnpres' ) ) ) ) ,
129- affectedChannelGroups : Array . from ( new Set ( this . groups . filter ( ( g ) => ! g . endsWith ( '-pnpres' ) ) ) ) ,
128+ affectedChannels : Array . from ( new Set ( this . channels ) ) ,
129+ affectedChannelGroups : Array . from ( new Set ( this . groups ) ) ,
130130 currentTimetoken,
131131 } ) ;
132132 }
Original file line number Diff line number Diff line change @@ -128,8 +128,8 @@ export class EventEngine {
128128 // Manually emit SubscriptionChanged status event
129129 this . dependencies . emitStatus ( {
130130 category : categoryConstants . PNSubscriptionChangedCategory ,
131- affectedChannels : Array . from ( new Set ( this . channels . filter ( ( c ) => ! c . endsWith ( '-pnpres' ) ) ) ) ,
132- affectedChannelGroups : Array . from ( new Set ( this . groups . filter ( ( g ) => ! g . endsWith ( '-pnpres' ) ) ) ) ,
131+ affectedChannels : Array . from ( new Set ( this . channels ) ) ,
132+ affectedChannelGroups : Array . from ( new Set ( this . groups ) ) ,
133133 currentTimetoken,
134134 } ) ;
135135 }
You can’t perform that action at this time.
0 commit comments