@@ -16,7 +16,7 @@ import { Inviter } from './inviter';
1616import { createFrozenProxy } from './lib/freeze' ;
1717import { log } from './logger' ;
1818import { ISession , SessionImpl } from './session' ;
19- import { statusFromDialog , cseqFromDialog } from './subscription' ;
19+ import { statusFromDialog } from './subscription' ;
2020import { second } from './time' ;
2121import { ITransport , ReconnectableTransport , TransportFactory , UAFactory } from './transport' ;
2222import { IClientOptions , IMedia } from './types' ;
@@ -149,7 +149,6 @@ export class ClientImpl extends EventEmitter implements IClient {
149149
150150 private readonly sessions : { [ index : string ] : SessionImpl } = { } ;
151151 private subscriptions : { [ index : string ] : Subscriber } = { } ;
152- private subscriptionSequenceNumbers : { [ index : string ] : number } = { } ;
153152 private connected = false ;
154153
155154 private transportFactory : TransportFactory ;
@@ -252,14 +251,7 @@ export class ClientImpl extends EventEmitter implements IClient {
252251 this . subscriptions [ uri ] . delegate = {
253252 onNotify : ( notification : Notification ) => {
254253 notification . accept ( ) ;
255- // oldSequenceNumber will be defaulted to -1 if it is not set yet.
256- const oldSequenceNumber = this . subscriptionSequenceNumbers [ uri ] || - 1 ;
257- const currentSequenceNumber = cseqFromDialog ( notification ) ;
258-
259- if ( currentSequenceNumber > oldSequenceNumber ) {
260- this . subscriptionSequenceNumbers [ uri ] = currentSequenceNumber ;
261- this . emit ( 'subscriptionNotify' , uri , statusFromDialog ( notification ) ) ;
262- }
254+ this . emit ( 'subscriptionNotify' , uri , statusFromDialog ( notification ) ) ;
263255 }
264256 } ;
265257
@@ -467,7 +459,6 @@ export class ClientImpl extends EventEmitter implements IClient {
467459 this . subscriptions [ uri ] . dispose ( ) ;
468460 }
469461
470- delete this . subscriptionSequenceNumbers [ uri ] ;
471462 delete this . subscriptions [ uri ] ;
472463 }
473464
0 commit comments